client_helper

package
v1.1.27-debug Latest Latest
Warning

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

Go to latest
Published: Jun 11, 2020 License: MIT Imports: 18 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 NewRedisClient

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

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, opts []grpc.DialOption) (*ClientFactory, 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, CloseFn, error)

func (*ClientFactory) NewDevicedServiceClient

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

func (*ClientFactory) NewEvaluatordServiceClient added in v1.1.24

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

func (*ClientFactory) NewIdentityd2ServiceClient

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

func (*ClientFactory) NewModuleSerivceClient

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

func (*ClientFactory) NewPolicydServiceClient

func (f *ClientFactory) NewPolicydServiceClient(opts ...grpc.DialOption) (policyd_pb.PolicydServiceClient, CloseFn, 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 CloseFn

type CloseFn func() 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