client_helper

package

v1.1.5 Latest Latest Go to latest Published: Nov 14, 2019 License: MIT Imports: 14 Imported by: 1

Details

This section is empty.

View Source

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

func DefaultDialOption() []grpc.DialOption

func NewFloat32(x float32) *gpb.FloatValue

func NewRedisClient(args ...interface{}) (*redis.Client, error)

func NewString(s string) *gpb.StringValue

func NewUInt64(x uint64) *gpb.UInt64Value

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

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

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

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

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

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

func (f *ClientFactory) NewModuleSerivceClient(opts ...grpc.DialOption) (component_pb.ModuleServiceClient, CloseFn, error)

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

type ClientType int32

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

func (self ClientType) String() string

type CloseFn func() error

type ServiceConfig struct {
	Address string
}

type ServiceConfigs map[ClientType]ServiceConfig

func NewDefaultServiceConfigs(addr string) ServiceConfigs

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