Versions in this module Expand all Collapse all v0 v0.7.0 Dec 5, 2019 Changes in this version + const MaxMsgSize + const MethodBioHealth + const MethodCreateMS + const MethodGetAttachInfo + const MethodJoin + const MethodKillRank + const MethodListPools + const MethodNotifyReady + const MethodPoolCreate + const MethodPoolDeleteACL + const MethodPoolDestroy + const MethodPoolGetACL + const MethodPoolOverwriteACL + const MethodPoolUpdateACL + const MethodRequestCredentials + const MethodSetRank + const MethodSetUp + const MethodSmdDevs + const MethodSmdPools + const MethodStartMS + const MethodValidateCredentials + const ModuleMgmt + const ModuleSecurity + const ModuleSecurityAgent + const ModuleSrv + var Status_name = map[int32]string + var Status_value = map[string]int32 + type Call struct + Body []byte + Method int32 + Module int32 + Sequence int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Call) Descriptor() ([]byte, []int) + func (*Call) ProtoMessage() + func (dst *Call) XXX_Merge(src proto.Message) + func (m *Call) GetBody() []byte + func (m *Call) GetMethod() int32 + func (m *Call) GetModule() int32 + func (m *Call) GetSequence() int64 + func (m *Call) Reset() + func (m *Call) String() string + func (m *Call) XXX_DiscardUnknown() + func (m *Call) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Call) XXX_Size() int + func (m *Call) XXX_Unmarshal(b []byte) error + type ClientConnection struct + func NewClientConnection(socket string) *ClientConnection + func (c *ClientConnection) Close() error + func (c *ClientConnection) Connect() error + func (c *ClientConnection) IsConnected() bool + func (c *ClientConnection) SendMsg(msg *Call) (*Response, error) + type DomainSocketClient interface + Close func() error + Connect func() error + IsConnected func() bool + SendMsg func(call *Call) (*Response, error) + type DomainSocketServer struct + func NewDomainSocketServer(ctx context.Context, log logging.Logger, sock string) (*DomainSocketServer, error) + func (d *DomainSocketServer) Listen() + func (d *DomainSocketServer) RegisterRPCModule(mod Module) + func (d *DomainSocketServer) Shutdown() + func (d *DomainSocketServer) Start() error + type Module interface + HandleCall func(*Session, int32, []byte) ([]byte, error) + ID func() int32 + type ModuleService struct + func NewModuleService(log logging.Logger) *ModuleService + func (r *ModuleService) GetModule(id int32) (Module, bool) + func (r *ModuleService) ProcessMessage(session *Session, msgBytes []byte) ([]byte, error) + func (r *ModuleService) RegisterModule(mod Module) error + type Response struct + Body []byte + Sequence int64 + Status Status + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (dst *Response) XXX_Merge(src proto.Message) + func (m *Response) GetBody() []byte + func (m *Response) GetSequence() int64 + func (m *Response) GetStatus() Status + func (m *Response) Reset() + func (m *Response) String() string + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type Session struct + Conn net.Conn + func NewSession(conn net.Conn, svc *ModuleService) *Session + func (s *Session) Close() + func (s *Session) ProcessIncomingMessage() error + type Status int32 + const Status_FAILURE + const Status_SUBMITTED + const Status_SUCCESS + const Status_UNKNOWN_METHOD + const Status_UNKNOWN_MODULE + func (Status) EnumDescriptor() ([]byte, []int) + func (x Status) String() string
Go to main page