aserto

Dec 3, 2024

Changes in this version

type Config

+ NoProxy bool

type ConnectionOption

+ func WithNoProxy(noProxy bool) ConnectionOption

Nov 14, 2024

Changes in this version

+ type TLSConfig struct

+ CA string

+ Cert string

+ Key string

+ func (c *TLSConfig) ClientConfig(skipVerify bool) (*tls.Config, error)

+ func (c *TLSConfig) ClientCredentials(skipVerify bool) (credentials.TransportCredentials, error)

+ func (c *TLSConfig) HasCA() bool

+ func (c *TLSConfig) HasCert() bool

+ func (c *TLSConfig) ServerConfig() (*tls.Config, error)

+ func (c *TLSConfig) ServerCredentials() (credentials.TransportCredentials, error)

Nov 11, 2024

Changes in this version

+ var ErrInvalidConfig = errors.New("invalid configuration")

+ func SetAccountContext(ctx context.Context, accountID string) context.Context

type Config

+ AccountID string

+ NoTLS bool

+ func (cfg *Config) Connect(opts ...ConnectionOption) (*grpc.ClientConn, error)

type ConnectionOption

+ func WithAccountID(accountID string) ConnectionOption

+ func WithClientCert(certPath, keyPath string) ConnectionOption

+ func WithHeader(key, value string) ConnectionOption

+ func WithNoTLS(noTLS bool) ConnectionOption

type ConnectionOptions

+ func (o *ConnectionOptions) Apply(opts ...ConnectionOption) error

+ func (o *ConnectionOptions) ToDialOptions() ([]grpc.DialOption, error)

Aug 9, 2024

Changes in this version

+ var ErrInvalidOptions = errors.New("invalid connection options")

+ func Connect(options *ConnectionOptions) (*grpc.ClientConn, error)

+ func NewConnection(opts ...ConnectionOption) (*grpc.ClientConn, error)

+ func SetSessionContext(ctx context.Context, sessionID string) context.Context

+ func SetTenantContext(ctx context.Context, tenantID string) context.Context

+ type Config struct

+ APIKey string

+ Address string

+ CACertPath string

+ ClientCertPath string

+ ClientKeyPath string

+ Headers map[string]string

+ Insecure bool

+ TenantID string

+ TimeoutInSeconds int

+ Token string

+ func (cfg *Config) ToConnectionOptions(dop DialOptionsProvider) ([]ConnectionOption, error)

+ type ConnectionOption func(*ConnectionOptions) error

+ func WithAPIKeyAuth(key string) ConnectionOption

+ func WithAddr(addr string) ConnectionOption

+ func WithCACertPath(path string) ConnectionOption

+ func WithChainStreamInterceptor(mw ...grpc.StreamClientInterceptor) ConnectionOption

+ func WithChainUnaryInterceptor(mw ...grpc.UnaryClientInterceptor) ConnectionOption

+ func WithDialOptions(opts ...grpc.DialOption) ConnectionOption

+ func WithInsecure(insecure bool) ConnectionOption

+ func WithSessionID(sessionID string) ConnectionOption

+ func WithTenantID(tenantID string) ConnectionOption

+ func WithTokenAuth(token string) ConnectionOption

+ func WithURL(svcURL *url.URL) ConnectionOption

+ type ConnectionOptionErrors []error

+ func (errs ConnectionOptionErrors) Error() string

+ type ConnectionOptions struct

+ Address string

+ CACertPath string

+ Creds credentials.PerRPCCredentials

+ DialOptions []grpc.DialOption

+ Insecure bool

+ SessionID string

+ StreamClientInterceptors []grpc.StreamClientInterceptor

+ TenantID string

+ URL *url.URL

+ UnaryClientInterceptors []grpc.UnaryClientInterceptor

+ func NewConnectionOptions(opts ...ConnectionOption) (*ConnectionOptions, error)

+ func (o *ConnectionOptions) ServerAddress() string

+ type DialOptionsProvider func(*Config) ([]grpc.DialOption, error)

+ func NewDialOptionsProvider(dialopts ...grpc.DialOption) DialOptionsProvider