grpc

Documentation

Index

• Constants
• type ClientMetadata
  • func NewClientMetadata(host string, port string, isStandaloneMode bool) *ClientMetadata
  • func (cm *ClientMetadata) GetBinaryVersion() string
  • func (cm *ClientMetadata) GetHost() string
  • func (cm *ClientMetadata) GetOptions() []grpc.DialOption
  • func (cm *ClientMetadata) GetPort() string
  • func (cm *ClientMetadata) WithBinaryVersion(version string) *ClientMetadata
  • func (cm *ClientMetadata) WithClientCertificate() *ClientMetadata
  • func (cm *ClientMetadata) WithInsecureTransport() *ClientMetadata
• type RemoteWorkProcessorGrpcClient
  • func NewClient(metadata meta.RemoteWorkProcessorMetadata, isStandaloneMode bool) *RemoteWorkProcessorGrpcClient
  • func (gc *RemoteWorkProcessorGrpcClient) InitSession(baseCtx context.Context, sessionID string) error
  • func (gc *RemoteWorkProcessorGrpcClient) ReceiveMsg() (*pb.ServerMessage, error)
  • func (gc *RemoteWorkProcessorGrpcClient) Send(op *pb.ClientMessage) error

Constants

const (
	CERTIFICATE_MOUTH_PATH = "/etc/auth/"
	CERTIFICATE_KEY        = "crt"
	PRIVATE_KEY            = "pk"
)

Types

type ClientMetadata

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

func NewClientMetadata

func NewClientMetadata(host string, port string, isStandaloneMode bool) *ClientMetadata

func (*ClientMetadata) GetBinaryVersion

func (cm *ClientMetadata) GetBinaryVersion() string

func (*ClientMetadata) GetHost

func (cm *ClientMetadata) GetHost() string

func (*ClientMetadata) GetOptions

func (cm *ClientMetadata) GetOptions() []grpc.DialOption

func (*ClientMetadata) GetPort

func (cm *ClientMetadata) GetPort() string

func (*ClientMetadata) WithBinaryVersion

func (cm *ClientMetadata) WithBinaryVersion(version string) *ClientMetadata

func (*ClientMetadata) WithClientCertificate

func (cm *ClientMetadata) WithClientCertificate() *ClientMetadata

func (*ClientMetadata) WithInsecureTransport

func (cm *ClientMetadata) WithInsecureTransport() *ClientMetadata

type RemoteWorkProcessorGrpcClient

type RemoteWorkProcessorGrpcClient struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewClient

func NewClient(metadata meta.RemoteWorkProcessorMetadata, isStandaloneMode bool) *RemoteWorkProcessorGrpcClient

func (*RemoteWorkProcessorGrpcClient) InitSession

func (gc *RemoteWorkProcessorGrpcClient) InitSession(baseCtx context.Context, sessionID string) error

func (*RemoteWorkProcessorGrpcClient) ReceiveMsg

func (gc *RemoteWorkProcessorGrpcClient) ReceiveMsg() (*pb.ServerMessage, error)

func (*RemoteWorkProcessorGrpcClient) Send

func (gc *RemoteWorkProcessorGrpcClient) Send(op *pb.ClientMessage) error