connector

Documentation

Index

• Variables
• func NewWrapper(ctx context.Context, server interface{}, opts ...Option) (*wrapper, error)
• type Option
  • func WithRateLimitDescriptor(entry *ratelimitV1.RateLimitDescriptors_Entry) Option
  • func WithRateLimiterConfig(cfg *ratelimitV1.RateLimiterConfig) Option

Variables

var ErrConnectorNotImplemented = errors.New("client does not implement connector connectorV2")

Functions

func NewWrapper

func NewWrapper(ctx context.Context, server interface{}, opts ...Option) (*wrapper, error)

NewConnectorWrapper returns a connector wrapper for running connector services locally.

Types

type Option

type Option func(ctx context.Context, w *wrapper) error

func WithRateLimitDescriptor

func WithRateLimitDescriptor(entry *ratelimitV1.RateLimitDescriptors_Entry) Option

func WithRateLimiterConfig

func WithRateLimiterConfig(cfg *ratelimitV1.RateLimiterConfig) Option