client_helper

Documentation

Index

• Variables
• func DefaultDialOption() []grpc.DialOption
• func NewClientTransportCredentials(cert_file, key_file string, plain_text, insecure bool) (credentials.TransportCredentials, error)
• func NewFloat32(x float32) *gpb.FloatValue
• func NewServerTransportCredentials(cert_file, key_file string) (credentials.TransportCredentials, error)
• func NewString(s string) *gpb.StringValue
• func NewUInt64(x uint64) *gpb.UInt64Value
• func ToClientFactory(v **ClientFactory) func(string, interface{}) error
• func ToMinioClient(v **minio.Client) func(string, any) error
• type ClientFactory
  • func NewClientFactory(configs ServiceConfigs, dial_opts []grpc.DialOption, ...) (*ClientFactory, error)
  • func (f *ClientFactory) GetConnection(cfg_val ClientType, opts ...grpc.DialOption) (*grpc.ClientConn, DoneFn, error)
  • func (f *ClientFactory) NewConnection(cfg_val ClientType, opts ...grpc.DialOption) (*grpc.ClientConn, error)
  • func (f *ClientFactory) NewDeviceServiceClient(opts ...grpc.DialOption) (device_pb.DeviceServiceClient, DoneFn, error)
  • func (f *ClientFactory) NewDevicedServiceClient(opts ...grpc.DialOption) (deviced_pb.DevicedServiceClient, DoneFn, error)
  • func (f *ClientFactory) NewEvaluatordServiceClient(opts ...grpc.DialOption) (evaluatord_pb.EvaluatordServiceClient, DoneFn, error)
  • func (f *ClientFactory) NewIdentityd2ServiceClient(opts ...grpc.DialOption) (identityd2_pb.IdentitydServiceClient, DoneFn, error)
  • func (f *ClientFactory) NewModuleServiceClient(opts ...grpc.DialOption) (component_pb.ModuleServiceClient, DoneFn, error)
  • func (f *ClientFactory) NewPolicydServiceClient(opts ...grpc.DialOption) (policyd_pb.PolicydServiceClient, DoneFn, error)
• type ClientType
  • func (self ClientType) String() string
• type DoneFn
• type NewClientFactoryOption
  • func SetDialPoolSize(siz int32) NewClientFactoryOption
• type RedisClient
  • func NewRedisClient(args ...interface{}) (RedisClient, error)
• type ServiceConfig
• type ServiceConfigs
  • func NewDefaultServiceConfigs(addr string, cred credentials.TransportCredentials) ServiceConfigs
  • func (self ServiceConfigs) SetServiceConfig(typ ClientType, cfg ServiceConfig)

Variables

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

Functions

func DefaultDialOption

func DefaultDialOption() []grpc.DialOption

func NewClientTransportCredentials

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

func NewFloat32

func NewFloat32(x float32) *gpb.FloatValue

func NewServerTransportCredentials

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

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

func ToMinioClient

func ToMinioClient(v **minio.Client) func(string, any) 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

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

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

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

type DoneFn func() error

type NewClientFactoryOption

type NewClientFactoryOption func(*newClientFactoryOption)

func SetDialPoolSize

func SetDialPoolSize(siz int32) NewClientFactoryOption

type RedisClient

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)