wehub-resource-sync
e071084ebe
govulncheck / govulncheck (push) Waiting to run
Harness (E2E) / Harnesses (mock LLM) (push) Waiting to run
Harness (E2E) / Provider harnesses (live LLM conformance) (push) Waiting to run
Lint / golangci-lint (push) Waiting to run
Run Tests / Unit Tests (push) Waiting to run
Run Tests / Etcd Integration Tests (push) Waiting to run
51 lines
818 B
Go
51 lines
818 B
Go
package source
|
|
|
|
import (
|
|
"context"
|
|
|
|
"go-micro.dev/v6/client"
|
|
"go-micro.dev/v6/config/encoder"
|
|
"go-micro.dev/v6/config/encoder/json"
|
|
)
|
|
|
|
type Options struct {
|
|
// Encoder
|
|
Encoder encoder.Encoder
|
|
|
|
// for alternative data
|
|
Context context.Context
|
|
|
|
// Client to use for RPC
|
|
Client client.Client
|
|
}
|
|
|
|
type Option func(o *Options)
|
|
|
|
func NewOptions(opts ...Option) Options {
|
|
options := Options{
|
|
Encoder: json.NewEncoder(),
|
|
Context: context.Background(),
|
|
Client: client.DefaultClient,
|
|
}
|
|
|
|
for _, o := range opts {
|
|
o(&options)
|
|
}
|
|
|
|
return options
|
|
}
|
|
|
|
// WithEncoder sets the source encoder.
|
|
func WithEncoder(e encoder.Encoder) Option {
|
|
return func(o *Options) {
|
|
o.Encoder = e
|
|
}
|
|
}
|
|
|
|
// WithClient sets the source client.
|
|
func WithClient(c client.Client) Option {
|
|
return func(o *Options) {
|
|
o.Client = c
|
|
}
|
|
}
|