Scott Blum dragonsinth
dragonsinth
/ concurrency_advice.go
Created
November 3, 2022 13:55
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package concurrency | |
| import ( | |
| "context" | |
| "fmt" | |
| "golang.org/x/sync/errgroup" | |
| ) | |
| const ( | |
| doThingWorkers = 4 |
dragonsinth
/ gazelle-local-repositores.go
Created
September 22, 2022 15:53
Generate local repository rules from a go.work file that uses on-disk replacements
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ///usr/bin/env true; exec /usr/bin/env go run "$0" "$@" | |
| package main | |
| import ( | |
| "fmt" | |
| "log" | |
| "os" | |
| "os/exec" | |
| "path/filepath" |
dragonsinth
/ chatterbox.sh
Created
December 17, 2021 15:18
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| go install github.com/fullstorydev/go/examples/chatterbox/...@latest | |
| chatterbox server | |
| chatterbox monitor # in another terminal | |
| chatterbox client # in another terminal |
dragonsinth
/ eventstream_model.go
Created
December 16, 2021 17:50
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| type LogReplicatedModel struct { | |
| mu sync.RWMutex | |
| snapshot Model | |
| stream eventstream.EventStream | |
| } | |
| func (m *LogReplicatedModel) ReadAndSubscribe() (Model, eventstream.Promise) { | |
| m.mu.RLock() | |
| defer m.mu.RUnlock() | |
| return m.snapshot, m.stream.Subscribe() |
dragonsinth
/ eventstream_iterator.go
Last active
December 17, 2021 12:28
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| for it := eventStream.Subscribe().Iterator(); true; { | |
| v, err := it.Next(ctx) | |
| if err == eventstream.ErrDone { | |
| return nil | |
| } else if err != nil { | |
| return err | |
| } | |
| msg := v.(bwamp.Event) | |
| // [Send msg to client] | |
| } |
dragonsinth
/ eventstream_promise.go
Last active
December 17, 2021 12:25
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| promise := eventStream.Subscribe() | |
| for { | |
| select { | |
| case <-ctx.Done(): | |
| return ctx.Err() | |
| case <-promise.Ready(): | |
| v, nextPromise := promise.Next() | |
| if v == nil { | |
| return nil | |
| } |
dragonsinth
/ eventstream_node.go
Created
December 16, 2021 17:45
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| type node struct { | |
| value interface{} // the value of the event (nil until ready) | |
| next *node // the next node in the stream (nil until ready) | |
| ready chan struct{} // a channel whose closure marks readiness | |
| } |
dragonsinth
/ gcp-kube.go
Last active
August 1, 2024 13:47
Connect to Google Kubernetes with GCP credentials and pure Golang
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package main | |
| import ( | |
| "context" | |
| "encoding/base64" | |
| "flag" | |
| "fmt" | |
| "log" | |
| container "google.golang.org/api/container/v1beta1" |
dragonsinth
/ getfriends_serial.go
Created
February 14, 2020 22:08
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| func GetFriends(ctx context.Context, user int64) (map[string]*User, error) { | |
| // Produce | |
| var friendIds []int64 | |
| for it := GetFriendIds(user); ; { | |
| if id, err := it.Next(ctx); err != nil { | |
| if err == io.EOF { | |
| break | |
| } | |
| return nil, fmt.Errorf("GetFriendIds %d: %w", user, err) | |
| } else { |
dragonsinth
/ getfriends_parallel.go
Created
February 14, 2020 22:07
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| func GetFriends(ctx context.Context, user int64) (map[string]*User, error) { | |
| friendIds := make(chan int64) | |
| // Produce | |
| go func() { | |
| defer close(friendIds) | |
| for it := GetFriendIds(user); ; { | |
| if id, err := it.Next(ctx); err != nil { | |
| if err == io.EOF { | |
| break |
NewerOlder