client_helper

package
v1.2.12 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 12, 2021 License: MIT Imports: 20 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidArgument      = errors.New("invalid argument")
	ErrMissingDefaultConfig = errors.New("require default config")
)

Functions

func DefaultDialOption added in v1.1.2

func DefaultDialOption() []grpc.DialOption

func NewClientTransportCredentials added in v1.1.10

func NewClientTransportCredentials(cert_file, key_file string, plain_text, insecure bool) (credentials.TransportCredentials, error)

func NewFloat32

func NewFloat32(x float32) *gpb.FloatValue

func NewServerTransportCredentials added in v1.1.10

func NewServerTransportCredentials(cert_file, key_file string) (credentials.TransportCredentials, error)

func NewString

func NewString(s string) *gpb.StringValue

func NewUInt64

func NewUInt64(x uint64) *gpb.UInt64Value

func ToClientFactory added in v1.1.26

func ToClientFactory(v **ClientFactory) func(string, interface{}) error

Types

type ClientFactory

type ClientFactory struct {
	// contains filtered or unexported fields
}

func NewClientFactory

func NewClientFactory(configs ServiceConfigs, dial_opts []grpc.DialOption, opts ...NewClientFactoryOption) (*ClientFactory, error)

func (*ClientFactory) GetConnection added in v1.2.11

func (f *ClientFactory) GetConnection(cfg_val ClientType, opts ...grpc.DialOption) (*grpc.ClientConn, DoneFn, error)

func (*ClientFactory) NewConnection

func (f *ClientFactory) NewConnection(cfg_val ClientType, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func (*ClientFactory) NewDeviceServiceClient

func (f *ClientFactory) NewDeviceServiceClient(opts ...grpc.DialOption) (device_pb.DeviceServiceClient, DoneFn, error)

func (*ClientFactory) NewDevicedServiceClient

func (f *ClientFactory) NewDevicedServiceClient(opts ...grpc.DialOption) (deviced_pb.DevicedServiceClient, DoneFn, error)

func (*ClientFactory) NewEvaluatordServiceClient added in v1.1.24

func (f *ClientFactory) NewEvaluatordServiceClient(opts ...grpc.DialOption) (evaluatord_pb.EvaluatordServiceClient, DoneFn, error)

func (*ClientFactory) NewIdentityd2ServiceClient

func (f *ClientFactory) NewIdentityd2ServiceClient(opts ...grpc.DialOption) (identityd2_pb.IdentitydServiceClient, DoneFn, error)

func (*ClientFactory) NewModuleServiceClient added in v1.2.0

func (f *ClientFactory) NewModuleServiceClient(opts ...grpc.DialOption) (component_pb.ModuleServiceClient, DoneFn, error)

func (*ClientFactory) NewPolicydServiceClient

func (f *ClientFactory) NewPolicydServiceClient(opts ...grpc.DialOption) (policyd_pb.PolicydServiceClient, DoneFn, error)

type ClientType

type ClientType int32
const (
	DEFAULT_CONFIG ClientType = iota
	POLICYD_CONFIG
	IDENTITYD2_CONFIG
	DEVICED_CONFIG
	EVALUATORD_CONFIG
	DEVICE_CONFIG
	MODULE_CONFIG
	OVERFLOW_CONFIG
)

func (ClientType) String

func (self ClientType) String() string

type DoneFn added in v1.2.11

type DoneFn func() error

type NewClientFactoryOption added in v1.2.11

type NewClientFactoryOption func(*newClientFactoryOption)

func SetDialPoolSize added in v1.2.11

func SetDialPoolSize(siz int32) NewClientFactoryOption

type RedisClient added in v1.2.4

type RedisClient interface {
	redis.Cmdable
	Close() error
}

func NewRedisClient

func NewRedisClient(args ...interface{}) (RedisClient, error)

type ServiceConfig

type ServiceConfig struct {
	Address              string
	TransportCredentials credentials.TransportCredentials
}

type ServiceConfigs

type ServiceConfigs map[ClientType]ServiceConfig

func NewDefaultServiceConfigs

func NewDefaultServiceConfigs(addr string, cred credentials.TransportCredentials) ServiceConfigs

func (ServiceConfigs) SetServiceConfig

func (self ServiceConfigs) SetServiceConfig(typ ClientType, cfg ServiceConfig)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL