Versions in this module Expand all Collapse all v0 v0.1.1 Oct 24, 2023 v0.1.0 Oct 23, 2023 Changes in this version + var UnhandledError error = errors.New("an unhandled gRPC error occurred") + func WithPreSharedKey(key string) grpc.DialOption + type Client interface + Check func(ctx context.Context, model string, as string) (bool, error) + Connect func(ctx context.Context) error + Pull func(ctx context.Context, model string, to graph.Destination, as string) error + Push func(ctx context.Context, model string, from graph.Source, as string) error + func New(ctx context.Context, target string, opt ...ClientOption) (Client, error) + type ClientOption func(c *client) error + func WithDialOptions(opt ...grpc.DialOption) ClientOption + func WithMetrics(reg prometheus.Registerer) ClientOption + func WithPeerName(name string) ClientOption + func WithTLS(config *tls.Config) ClientOption + type MetricsCollector struct + func (mc *MetricsCollector) For(md api.Metadata) RequestMetricsCollector + type RequestMetricsCollector interface + Acknowledged func() + Erred func() + Pulled func() + Pushed func()
Go to main page