Documentation
¶
Index ¶
- func RegisterCabalServer(s *grpc.Server, srv CabalServer)
- func RegisterControlServer(s *grpc.Server, srv ControlServer)
- func RegisterRemoteServer(s *grpc.Server, srv RemoteServer)
- type Action
- func (*Action) Descriptor() ([]byte, []int)
- func (m *Action) GetError() string
- func (m *Action) GetMessage() string
- func (m *Action) GetRemoteID() string
- func (m *Action) GetRequest() string
- func (m *Action) GetTarget() string
- func (*Action) ProtoMessage()
- func (m *Action) Reset()
- func (m *Action) String() string
- func (m *Action) XXX_DiscardUnknown()
- func (m *Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Action) XXX_Merge(src proto.Message)
- func (m *Action) XXX_Size() int
- func (m *Action) XXX_Unmarshal(b []byte) error
- type CabalClient
- type CabalServer
- type ControlClient
- type ControlServer
- type CoreService
- func (*CoreService) Descriptor() ([]byte, []int)
- func (m *CoreService) GetAddress() string
- func (m *CoreService) GetErrors() []string
- func (m *CoreService) GetMode() string
- func (m *CoreService) GetName() string
- func (m *CoreService) GetParentID() string
- func (m *CoreService) GetPeerGroups() []string
- func (*CoreService) ProtoMessage()
- func (m *CoreService) Reset()
- func (m *CoreService) String() string
- func (m *CoreService) XXX_DiscardUnknown()
- func (m *CoreService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CoreService) XXX_Merge(src proto.Message)
- func (m *CoreService) XXX_Size() int
- func (m *CoreService) XXX_Unmarshal(b []byte) error
- type DataRequest
- func (*DataRequest) Descriptor() ([]byte, []int)
- func (m *DataRequest) GetError() string
- func (m *DataRequest) GetRequest() *Request
- func (*DataRequest) ProtoMessage()
- func (m *DataRequest) Reset()
- func (m *DataRequest) String() string
- func (m *DataRequest) XXX_DiscardUnknown()
- func (m *DataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataRequest) XXX_Merge(src proto.Message)
- func (m *DataRequest) XXX_Size() int
- func (m *DataRequest) XXX_Unmarshal(b []byte) error
- type DataResponse
- func (*DataResponse) Descriptor() ([]byte, []int)
- func (m *DataResponse) GetError() string
- func (m *DataResponse) GetResponder() *Responder
- func (*DataResponse) ProtoMessage()
- func (m *DataResponse) Reset()
- func (m *DataResponse) String() string
- func (m *DataResponse) XXX_DiscardUnknown()
- func (m *DataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataResponse) XXX_Merge(src proto.Message)
- func (m *DataResponse) XXX_Size() int
- func (m *DataResponse) XXX_Unmarshal(b []byte) error
- type EmptyRequest
- func (*EmptyRequest) Descriptor() ([]byte, []int)
- func (*EmptyRequest) ProtoMessage()
- func (m *EmptyRequest) Reset()
- func (m *EmptyRequest) String() string
- func (m *EmptyRequest) XXX_DiscardUnknown()
- func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyRequest) XXX_Merge(src proto.Message)
- func (m *EmptyRequest) XXX_Size() int
- func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
- type NewService
- func (*NewService) Descriptor() ([]byte, []int)
- func (m *NewService) GetAliases() []string
- func (m *NewService) GetIsClient() bool
- func (m *NewService) GetIsServer() bool
- func (m *NewService) GetName() string
- func (m *NewService) GetPeerGroups() []string
- func (*NewService) ProtoMessage()
- func (m *NewService) Reset()
- func (m *NewService) String() string
- func (m *NewService) XXX_DiscardUnknown()
- func (m *NewService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewService) XXX_Merge(src proto.Message)
- func (m *NewService) XXX_Size() int
- func (m *NewService) XXX_Unmarshal(b []byte) error
- type NewServiceRequest
- func (*NewServiceRequest) Descriptor() ([]byte, []int)
- func (m *NewServiceRequest) GetAddress() string
- func (m *NewServiceRequest) GetEnv() string
- func (m *NewServiceRequest) GetService() *NewService
- func (*NewServiceRequest) ProtoMessage()
- func (m *NewServiceRequest) Reset()
- func (m *NewServiceRequest) String() string
- func (m *NewServiceRequest) XXX_DiscardUnknown()
- func (m *NewServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NewServiceRequest) XXX_Merge(src proto.Message)
- func (m *NewServiceRequest) XXX_Size() int
- func (m *NewServiceRequest) XXX_Unmarshal(b []byte) error
- type Payload
- func (*Payload) Descriptor() ([]byte, []int)
- func (m *Payload) GetBoolFields() map[string]bool
- func (m *Payload) GetByteFields() map[string][]byte
- func (m *Payload) GetData() map[string]*any.Any
- func (m *Payload) GetDoubleFields() map[string]float64
- func (m *Payload) GetFields() map[string]*SubFields
- func (m *Payload) GetFloatFields() map[string]float32
- func (m *Payload) GetInt64Fields() map[string]int64
- func (m *Payload) GetIntFields() map[string]int32
- func (m *Payload) GetJSON() map[string][]byte
- func (m *Payload) GetTextFields() map[string]string
- func (m *Payload) GetUint64Fields() map[string]uint64
- func (m *Payload) GetUintFields() map[string]uint32
- func (*Payload) ProtoMessage()
- func (m *Payload) Reset()
- func (m *Payload) String() string
- func (m *Payload) XXX_DiscardUnknown()
- func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Payload) XXX_Merge(src proto.Message)
- func (m *Payload) XXX_Size() int
- func (m *Payload) XXX_Unmarshal(b []byte) error
- type Ping
- func (*Ping) Descriptor() ([]byte, []int)
- func (m *Ping) GetError() string
- func (m *Ping) GetStatus() string
- func (m *Ping) GetTime() string
- func (*Ping) ProtoMessage()
- func (m *Ping) Reset()
- func (m *Ping) String() string
- func (m *Ping) XXX_DiscardUnknown()
- func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Ping) XXX_Merge(src proto.Message)
- func (m *Ping) XXX_Size() int
- func (m *Ping) XXX_Unmarshal(b []byte) error
- type Pong
- func (*Pong) Descriptor() ([]byte, []int)
- func (m *Pong) GetError() string
- func (m *Pong) GetStatus() string
- func (m *Pong) GetTime() string
- func (*Pong) ProtoMessage()
- func (m *Pong) Reset()
- func (m *Pong) String() string
- func (m *Pong) XXX_DiscardUnknown()
- func (m *Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Pong) XXX_Merge(src proto.Message)
- func (m *Pong) XXX_Size() int
- func (m *Pong) XXX_Unmarshal(b []byte) error
- type ProcessManager
- func (*ProcessManager) Descriptor() ([]byte, []int)
- func (m *ProcessManager) GetAddress() string
- func (m *ProcessManager) GetErrors() []string
- func (m *ProcessManager) GetID() string
- func (m *ProcessManager) GetLogPath() string
- func (m *ProcessManager) GetName() string
- func (m *ProcessManager) GetServices() []*Service
- func (m *ProcessManager) GetStartTime() string
- func (m *ProcessManager) GetStatus() string
- func (*ProcessManager) ProtoMessage()
- func (m *ProcessManager) Reset()
- func (m *ProcessManager) String() string
- func (m *ProcessManager) XXX_DiscardUnknown()
- func (m *ProcessManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ProcessManager) XXX_Merge(src proto.Message)
- func (m *ProcessManager) XXX_Size() int
- func (m *ProcessManager) XXX_Unmarshal(b []byte) error
- type Receipt
- func (*Receipt) Descriptor() ([]byte, []int)
- func (m *Receipt) GetError() string
- func (m *Receipt) GetFollowup() string
- func (m *Receipt) GetMessage() string
- func (m *Receipt) GetServiceInfo() *ServiceSummary
- func (*Receipt) ProtoMessage()
- func (m *Receipt) Reset()
- func (m *Receipt) String() string
- func (m *Receipt) XXX_DiscardUnknown()
- func (m *Receipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Receipt) XXX_Merge(src proto.Message)
- func (m *Receipt) XXX_Size() int
- func (m *Receipt) XXX_Unmarshal(b []byte) error
- type RemoteClient
- type RemoteServer
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetData1() string
- func (m *Request) GetMethod() string
- func (m *Request) GetPload() *Payload
- func (m *Request) GetSender() string
- func (m *Request) GetTarget() string
- func (m *Request) GetTport() *Transport
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) String() string
- func (m *Request) XXX_DiscardUnknown()
- func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Request) XXX_Merge(src proto.Message)
- func (m *Request) XXX_Size() int
- func (m *Request) XXX_Unmarshal(b []byte) error
- type Responder
- func (*Responder) Descriptor() ([]byte, []int)
- func (m *Responder) GetErr() string
- func (m *Responder) GetErrorString() string
- func (m *Responder) GetHadError() bool
- func (m *Responder) GetPload() *Payload
- func (m *Responder) GetResult() string
- func (m *Responder) GetTport() *Transport
- func (*Responder) ProtoMessage()
- func (m *Responder) Reset()
- func (m *Responder) String() string
- func (m *Responder) XXX_DiscardUnknown()
- func (m *Responder) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Responder) XXX_Merge(src proto.Message)
- func (m *Responder) XXX_Size() int
- func (m *Responder) XXX_Unmarshal(b []byte) error
- type Service
- func (*Service) Descriptor() ([]byte, []int)
- func (m *Service) GetAddress() string
- func (m *Service) GetErrors() []string
- func (m *Service) GetFailTime() string
- func (m *Service) GetFails() int32
- func (m *Service) GetId() string
- func (m *Service) GetLanguage() string
- func (m *Service) GetLogPath() string
- func (m *Service) GetMode() string
- func (m *Service) GetName() string
- func (m *Service) GetPath() string
- func (m *Service) GetPid() int32
- func (m *Service) GetRestarts() int32
- func (m *Service) GetStartTime() string
- func (m *Service) GetStatus() string
- func (*Service) ProtoMessage()
- func (m *Service) Reset()
- func (m *Service) String() string
- func (m *Service) XXX_DiscardUnknown()
- func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Service) XXX_Merge(src proto.Message)
- func (m *Service) XXX_Size() int
- func (m *Service) XXX_Unmarshal(b []byte) error
- type ServiceSummary
- func (*ServiceSummary) Descriptor() ([]byte, []int)
- func (m *ServiceSummary) GetAddress() string
- func (m *ServiceSummary) GetFingerprint() string
- func (m *ServiceSummary) GetID() string
- func (*ServiceSummary) ProtoMessage()
- func (m *ServiceSummary) Reset()
- func (m *ServiceSummary) String() string
- func (m *ServiceSummary) XXX_DiscardUnknown()
- func (m *ServiceSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceSummary) XXX_Merge(src proto.Message)
- func (m *ServiceSummary) XXX_Size() int
- func (m *ServiceSummary) XXX_Unmarshal(b []byte) error
- type ServiceUpdate
- func (*ServiceUpdate) Descriptor() ([]byte, []int)
- func (m *ServiceUpdate) GetAddress() string
- func (m *ServiceUpdate) GetEnv() string
- func (m *ServiceUpdate) GetError() string
- func (m *ServiceUpdate) GetMessage() string
- func (m *ServiceUpdate) GetRequest() string
- func (*ServiceUpdate) ProtoMessage()
- func (m *ServiceUpdate) Reset()
- func (m *ServiceUpdate) String() string
- func (m *ServiceUpdate) XXX_DiscardUnknown()
- func (m *ServiceUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceUpdate) XXX_Merge(src proto.Message)
- func (m *ServiceUpdate) XXX_Size() int
- func (m *ServiceUpdate) XXX_Unmarshal(b []byte) error
- type SubFields
- func (*SubFields) Descriptor() ([]byte, []int)
- func (m *SubFields) GetSub() []string
- func (*SubFields) ProtoMessage()
- func (m *SubFields) Reset()
- func (m *SubFields) String() string
- func (m *SubFields) XXX_DiscardUnknown()
- func (m *SubFields) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubFields) XXX_Merge(src proto.Message)
- func (m *SubFields) XXX_Size() int
- func (m *SubFields) XXX_Unmarshal(b []byte) error
- type SummaryReceipt
- func (*SummaryReceipt) Descriptor() ([]byte, []int)
- func (m *SummaryReceipt) GetError() string
- func (m *SummaryReceipt) GetRemotes() []*ProcessManager
- func (m *SummaryReceipt) GetServices() []*CoreService
- func (*SummaryReceipt) ProtoMessage()
- func (m *SummaryReceipt) Reset()
- func (m *SummaryReceipt) String() string
- func (m *SummaryReceipt) XXX_DiscardUnknown()
- func (m *SummaryReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SummaryReceipt) XXX_Merge(src proto.Message)
- func (m *SummaryReceipt) XXX_Size() int
- func (m *SummaryReceipt) XXX_Unmarshal(b []byte) error
- type Transport
- func (*Transport) Descriptor() ([]byte, []int)
- func (m *Transport) GetMethod() string
- func (m *Transport) GetSender() string
- func (m *Transport) GetTarget() string
- func (*Transport) ProtoMessage()
- func (m *Transport) Reset()
- func (m *Transport) String() string
- func (m *Transport) XXX_DiscardUnknown()
- func (m *Transport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Transport) XXX_Merge(src proto.Message)
- func (m *Transport) XXX_Size() int
- func (m *Transport) XXX_Unmarshal(b []byte) error
- type WhoIsRequest
- func (*WhoIsRequest) Descriptor() ([]byte, []int)
- func (m *WhoIsRequest) GetSender() string
- func (m *WhoIsRequest) GetTarget() string
- func (*WhoIsRequest) ProtoMessage()
- func (m *WhoIsRequest) Reset()
- func (m *WhoIsRequest) String() string
- func (m *WhoIsRequest) XXX_DiscardUnknown()
- func (m *WhoIsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WhoIsRequest) XXX_Merge(src proto.Message)
- func (m *WhoIsRequest) XXX_Size() int
- func (m *WhoIsRequest) XXX_Unmarshal(b []byte) error
- type WhoIsResponse
- func (*WhoIsResponse) Descriptor() ([]byte, []int)
- func (m *WhoIsResponse) GetError() string
- func (m *WhoIsResponse) GetTargetAddress() string
- func (*WhoIsResponse) ProtoMessage()
- func (m *WhoIsResponse) Reset()
- func (m *WhoIsResponse) String() string
- func (m *WhoIsResponse) XXX_DiscardUnknown()
- func (m *WhoIsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WhoIsResponse) XXX_Merge(src proto.Message)
- func (m *WhoIsResponse) XXX_Size() int
- func (m *WhoIsResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCabalServer ¶
func RegisterCabalServer(s *grpc.Server, srv CabalServer)
func RegisterControlServer ¶
func RegisterControlServer(s *grpc.Server, srv ControlServer)
func RegisterRemoteServer ¶
func RegisterRemoteServer(s *grpc.Server, srv RemoteServer)
Types ¶
type Action ¶
type Action struct { Request string `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"` Target string `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"` RemoteID string `protobuf:"bytes,5,opt,name=RemoteID,proto3" json:"RemoteID,omitempty"` Message string `protobuf:"bytes,4,opt,name=Message,proto3" json:"Message,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Action) Descriptor ¶
func (*Action) GetMessage ¶
func (*Action) GetRemoteID ¶
func (*Action) GetRequest ¶
func (*Action) ProtoMessage ¶
func (*Action) ProtoMessage()
func (*Action) XXX_DiscardUnknown ¶
func (m *Action) XXX_DiscardUnknown()
func (*Action) XXX_Marshal ¶
func (*Action) XXX_Unmarshal ¶
type CabalClient ¶
type CabalClient interface { RegisterService(ctx context.Context, in *NewServiceRequest, opts ...grpc.CallOption) (*Receipt, error) UpdateRegistration(ctx context.Context, in *ServiceUpdate, opts ...grpc.CallOption) (*Receipt, error) Data(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (*DataResponse, error) WhoIs(ctx context.Context, in *WhoIsRequest, opts ...grpc.CallOption) (*WhoIsResponse, error) Summary(ctx context.Context, in *Action, opts ...grpc.CallOption) (*SummaryReceipt, error) Alive(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Pong, error) }
CabalClient is the client API for Cabal service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCabalClient ¶
func NewCabalClient(cc *grpc.ClientConn) CabalClient
type CabalServer ¶
type CabalServer interface { RegisterService(context.Context, *NewServiceRequest) (*Receipt, error) UpdateRegistration(context.Context, *ServiceUpdate) (*Receipt, error) Data(context.Context, *DataRequest) (*DataResponse, error) WhoIs(context.Context, *WhoIsRequest) (*WhoIsResponse, error) Summary(context.Context, *Action) (*SummaryReceipt, error) Alive(context.Context, *Ping) (*Pong, error) }
CabalServer is the server API for Cabal service.
type ControlClient ¶
type ControlClient interface { StartService(ctx context.Context, in *Action, opts ...grpc.CallOption) (*Receipt, error) RestartService(ctx context.Context, in *Action, opts ...grpc.CallOption) (*Receipt, error) KillService(ctx context.Context, in *Action, opts ...grpc.CallOption) (*Receipt, error) Summary(ctx context.Context, in *Action, opts ...grpc.CallOption) (*SummaryReceipt, error) UpdateRegistration(ctx context.Context, in *ServiceUpdate, opts ...grpc.CallOption) (*Receipt, error) Alive(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Pong, error) StopServer(ctx context.Context, in *EmptyRequest, opts ...grpc.CallOption) (*Receipt, error) }
ControlClient is the client API for Control service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewControlClient ¶
func NewControlClient(cc *grpc.ClientConn) ControlClient
type ControlServer ¶
type ControlServer interface { StartService(context.Context, *Action) (*Receipt, error) RestartService(context.Context, *Action) (*Receipt, error) KillService(context.Context, *Action) (*Receipt, error) Summary(context.Context, *Action) (*SummaryReceipt, error) UpdateRegistration(context.Context, *ServiceUpdate) (*Receipt, error) Alive(context.Context, *Ping) (*Pong, error) StopServer(context.Context, *EmptyRequest) (*Receipt, error) }
ControlServer is the server API for Control service.
type CoreService ¶
type CoreService struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"` Mode string `protobuf:"bytes,3,opt,name=Mode,proto3" json:"Mode,omitempty"` // string GroupName = 6; PeerGroups []string `protobuf:"bytes,7,rep,name=PeerGroups,proto3" json:"PeerGroups,omitempty"` ParentID string `protobuf:"bytes,5,opt,name=ParentID,proto3" json:"ParentID,omitempty"` Errors []string `protobuf:"bytes,4,rep,name=Errors,proto3" json:"Errors,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CoreService) Descriptor ¶
func (*CoreService) Descriptor() ([]byte, []int)
func (*CoreService) GetAddress ¶
func (m *CoreService) GetAddress() string
func (*CoreService) GetErrors ¶
func (m *CoreService) GetErrors() []string
func (*CoreService) GetMode ¶
func (m *CoreService) GetMode() string
func (*CoreService) GetName ¶
func (m *CoreService) GetName() string
func (*CoreService) GetParentID ¶
func (m *CoreService) GetParentID() string
func (*CoreService) GetPeerGroups ¶ added in v0.9.5
func (m *CoreService) GetPeerGroups() []string
func (*CoreService) ProtoMessage ¶
func (*CoreService) ProtoMessage()
func (*CoreService) Reset ¶
func (m *CoreService) Reset()
func (*CoreService) String ¶
func (m *CoreService) String() string
func (*CoreService) XXX_DiscardUnknown ¶
func (m *CoreService) XXX_DiscardUnknown()
func (*CoreService) XXX_Marshal ¶
func (m *CoreService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CoreService) XXX_Merge ¶
func (m *CoreService) XXX_Merge(src proto.Message)
func (*CoreService) XXX_Size ¶
func (m *CoreService) XXX_Size() int
func (*CoreService) XXX_Unmarshal ¶
func (m *CoreService) XXX_Unmarshal(b []byte) error
type DataRequest ¶
type DataRequest struct { Request *Request `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"` Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataRequest) Descriptor ¶
func (*DataRequest) Descriptor() ([]byte, []int)
func (*DataRequest) GetError ¶
func (m *DataRequest) GetError() string
func (*DataRequest) GetRequest ¶
func (m *DataRequest) GetRequest() *Request
func (*DataRequest) ProtoMessage ¶
func (*DataRequest) ProtoMessage()
func (*DataRequest) Reset ¶
func (m *DataRequest) Reset()
func (*DataRequest) String ¶
func (m *DataRequest) String() string
func (*DataRequest) XXX_DiscardUnknown ¶
func (m *DataRequest) XXX_DiscardUnknown()
func (*DataRequest) XXX_Marshal ¶
func (m *DataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataRequest) XXX_Merge ¶
func (m *DataRequest) XXX_Merge(src proto.Message)
func (*DataRequest) XXX_Size ¶
func (m *DataRequest) XXX_Size() int
func (*DataRequest) XXX_Unmarshal ¶
func (m *DataRequest) XXX_Unmarshal(b []byte) error
type DataResponse ¶
type DataResponse struct { Responder *Responder `protobuf:"bytes,2,opt,name=Responder,proto3" json:"Responder,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataResponse) Descriptor ¶
func (*DataResponse) Descriptor() ([]byte, []int)
func (*DataResponse) GetError ¶
func (m *DataResponse) GetError() string
func (*DataResponse) GetResponder ¶
func (m *DataResponse) GetResponder() *Responder
func (*DataResponse) ProtoMessage ¶
func (*DataResponse) ProtoMessage()
func (*DataResponse) Reset ¶
func (m *DataResponse) Reset()
func (*DataResponse) String ¶
func (m *DataResponse) String() string
func (*DataResponse) XXX_DiscardUnknown ¶
func (m *DataResponse) XXX_DiscardUnknown()
func (*DataResponse) XXX_Marshal ¶
func (m *DataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataResponse) XXX_Merge ¶
func (m *DataResponse) XXX_Merge(src proto.Message)
func (*DataResponse) XXX_Size ¶
func (m *DataResponse) XXX_Size() int
func (*DataResponse) XXX_Unmarshal ¶
func (m *DataResponse) XXX_Unmarshal(b []byte) error
type EmptyRequest ¶
type EmptyRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EmptyRequest) Descriptor ¶
func (*EmptyRequest) Descriptor() ([]byte, []int)
func (*EmptyRequest) ProtoMessage ¶
func (*EmptyRequest) ProtoMessage()
func (*EmptyRequest) Reset ¶
func (m *EmptyRequest) Reset()
func (*EmptyRequest) String ¶
func (m *EmptyRequest) String() string
func (*EmptyRequest) XXX_DiscardUnknown ¶
func (m *EmptyRequest) XXX_DiscardUnknown()
func (*EmptyRequest) XXX_Marshal ¶
func (m *EmptyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyRequest) XXX_Merge ¶
func (m *EmptyRequest) XXX_Merge(src proto.Message)
func (*EmptyRequest) XXX_Size ¶
func (m *EmptyRequest) XXX_Size() int
func (*EmptyRequest) XXX_Unmarshal ¶
func (m *EmptyRequest) XXX_Unmarshal(b []byte) error
type NewService ¶
type NewService struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Aliases []string `protobuf:"bytes,2,rep,name=Aliases,proto3" json:"Aliases,omitempty"` IsServer bool `protobuf:"varint,3,opt,name=IsServer,proto3" json:"IsServer,omitempty"` IsClient bool `protobuf:"varint,4,opt,name=IsClient,proto3" json:"IsClient,omitempty"` // string PeerGroup = 5; PeerGroups []string `protobuf:"bytes,6,rep,name=PeerGroups,proto3" json:"PeerGroups,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NewService) Descriptor ¶
func (*NewService) Descriptor() ([]byte, []int)
func (*NewService) GetAliases ¶
func (m *NewService) GetAliases() []string
func (*NewService) GetIsClient ¶
func (m *NewService) GetIsClient() bool
func (*NewService) GetIsServer ¶
func (m *NewService) GetIsServer() bool
func (*NewService) GetName ¶
func (m *NewService) GetName() string
func (*NewService) GetPeerGroups ¶ added in v0.9.5
func (m *NewService) GetPeerGroups() []string
func (*NewService) ProtoMessage ¶
func (*NewService) ProtoMessage()
func (*NewService) Reset ¶
func (m *NewService) Reset()
func (*NewService) String ¶
func (m *NewService) String() string
func (*NewService) XXX_DiscardUnknown ¶
func (m *NewService) XXX_DiscardUnknown()
func (*NewService) XXX_Marshal ¶
func (m *NewService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewService) XXX_Merge ¶
func (m *NewService) XXX_Merge(src proto.Message)
func (*NewService) XXX_Size ¶
func (m *NewService) XXX_Size() int
func (*NewService) XXX_Unmarshal ¶
func (m *NewService) XXX_Unmarshal(b []byte) error
type NewServiceRequest ¶
type NewServiceRequest struct { Service *NewService `protobuf:"bytes,1,opt,name=Service,proto3" json:"Service,omitempty"` Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"` Env string `protobuf:"bytes,3,opt,name=Env,proto3" json:"Env,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NewServiceRequest) Descriptor ¶
func (*NewServiceRequest) Descriptor() ([]byte, []int)
func (*NewServiceRequest) GetAddress ¶ added in v0.9.5
func (m *NewServiceRequest) GetAddress() string
func (*NewServiceRequest) GetEnv ¶ added in v0.9.5
func (m *NewServiceRequest) GetEnv() string
func (*NewServiceRequest) GetService ¶
func (m *NewServiceRequest) GetService() *NewService
func (*NewServiceRequest) ProtoMessage ¶
func (*NewServiceRequest) ProtoMessage()
func (*NewServiceRequest) Reset ¶
func (m *NewServiceRequest) Reset()
func (*NewServiceRequest) String ¶
func (m *NewServiceRequest) String() string
func (*NewServiceRequest) XXX_DiscardUnknown ¶
func (m *NewServiceRequest) XXX_DiscardUnknown()
func (*NewServiceRequest) XXX_Marshal ¶
func (m *NewServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NewServiceRequest) XXX_Merge ¶
func (m *NewServiceRequest) XXX_Merge(src proto.Message)
func (*NewServiceRequest) XXX_Size ¶
func (m *NewServiceRequest) XXX_Size() int
func (*NewServiceRequest) XXX_Unmarshal ¶
func (m *NewServiceRequest) XXX_Unmarshal(b []byte) error
type Payload ¶ added in v0.9.4
type Payload struct { Fields map[string]*SubFields `` /* 154-byte string literal not displayed */ JSON map[string][]byte `` /* 150-byte string literal not displayed */ TextFields map[string]string `` /* 162-byte string literal not displayed */ BoolFields map[string]bool `` /* 163-byte string literal not displayed */ ByteFields map[string][]byte `` /* 162-byte string literal not displayed */ IntFields map[string]int32 `` /* 161-byte string literal not displayed */ Int64Fields map[string]int64 `` /* 165-byte string literal not displayed */ UintFields map[string]uint32 `` /* 163-byte string literal not displayed */ Uint64Fields map[string]uint64 `` /* 167-byte string literal not displayed */ DoubleFields map[string]float64 `` /* 168-byte string literal not displayed */ FloatFields map[string]float32 `` /* 166-byte string literal not displayed */ Data map[string]*any.Any `` /* 150-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Payload) Descriptor ¶ added in v0.9.4
func (*Payload) GetBoolFields ¶ added in v0.9.4
func (*Payload) GetByteFields ¶ added in v0.9.4
func (*Payload) GetDoubleFields ¶ added in v0.9.4
func (*Payload) GetFloatFields ¶ added in v0.9.4
func (*Payload) GetInt64Fields ¶ added in v0.9.4
func (*Payload) GetIntFields ¶ added in v0.9.4
func (*Payload) GetTextFields ¶ added in v0.9.4
func (*Payload) GetUint64Fields ¶ added in v0.9.4
func (*Payload) GetUintFields ¶ added in v0.9.4
func (*Payload) ProtoMessage ¶ added in v0.9.4
func (*Payload) ProtoMessage()
func (*Payload) XXX_DiscardUnknown ¶ added in v0.9.4
func (m *Payload) XXX_DiscardUnknown()
func (*Payload) XXX_Marshal ¶ added in v0.9.4
func (*Payload) XXX_Unmarshal ¶ added in v0.9.4
type Ping ¶
type Ping struct { Status string `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"` Time string `protobuf:"bytes,2,opt,name=Time,proto3" json:"Time,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Ping) Descriptor ¶
func (*Ping) ProtoMessage ¶
func (*Ping) ProtoMessage()
func (*Ping) XXX_DiscardUnknown ¶
func (m *Ping) XXX_DiscardUnknown()
func (*Ping) XXX_Unmarshal ¶
type Pong ¶
type Pong struct { Status string `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"` Time string `protobuf:"bytes,2,opt,name=Time,proto3" json:"Time,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Pong) Descriptor ¶
func (*Pong) ProtoMessage ¶
func (*Pong) ProtoMessage()
func (*Pong) XXX_DiscardUnknown ¶
func (m *Pong) XXX_DiscardUnknown()
func (*Pong) XXX_Unmarshal ¶
type ProcessManager ¶
type ProcessManager struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` Address string `protobuf:"bytes,3,opt,name=Address,proto3" json:"Address,omitempty"` StartTime string `protobuf:"bytes,5,opt,name=StartTime,proto3" json:"StartTime,omitempty"` Errors []string `protobuf:"bytes,8,rep,name=Errors,proto3" json:"Errors,omitempty"` Status string `protobuf:"bytes,7,opt,name=Status,proto3" json:"Status,omitempty"` LogPath string `protobuf:"bytes,9,opt,name=LogPath,proto3" json:"LogPath,omitempty"` Services []*Service `protobuf:"bytes,4,rep,name=Services,proto3" json:"Services,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ProcessManager) Descriptor ¶
func (*ProcessManager) Descriptor() ([]byte, []int)
func (*ProcessManager) GetAddress ¶
func (m *ProcessManager) GetAddress() string
func (*ProcessManager) GetErrors ¶
func (m *ProcessManager) GetErrors() []string
func (*ProcessManager) GetID ¶
func (m *ProcessManager) GetID() string
func (*ProcessManager) GetLogPath ¶ added in v0.9.3
func (m *ProcessManager) GetLogPath() string
func (*ProcessManager) GetName ¶
func (m *ProcessManager) GetName() string
func (*ProcessManager) GetServices ¶
func (m *ProcessManager) GetServices() []*Service
func (*ProcessManager) GetStartTime ¶
func (m *ProcessManager) GetStartTime() string
func (*ProcessManager) GetStatus ¶
func (m *ProcessManager) GetStatus() string
func (*ProcessManager) ProtoMessage ¶
func (*ProcessManager) ProtoMessage()
func (*ProcessManager) Reset ¶
func (m *ProcessManager) Reset()
func (*ProcessManager) String ¶
func (m *ProcessManager) String() string
func (*ProcessManager) XXX_DiscardUnknown ¶
func (m *ProcessManager) XXX_DiscardUnknown()
func (*ProcessManager) XXX_Marshal ¶
func (m *ProcessManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProcessManager) XXX_Merge ¶
func (m *ProcessManager) XXX_Merge(src proto.Message)
func (*ProcessManager) XXX_Size ¶
func (m *ProcessManager) XXX_Size() int
func (*ProcessManager) XXX_Unmarshal ¶
func (m *ProcessManager) XXX_Unmarshal(b []byte) error
type Receipt ¶
type Receipt struct { ServiceInfo *ServiceSummary `protobuf:"bytes,1,opt,name=serviceInfo,proto3" json:"serviceInfo,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` Followup string `protobuf:"bytes,3,opt,name=Followup,proto3" json:"Followup,omitempty"` Error string `protobuf:"bytes,10,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Receipt) Descriptor ¶
func (*Receipt) GetFollowup ¶
func (*Receipt) GetMessage ¶
func (*Receipt) GetServiceInfo ¶
func (m *Receipt) GetServiceInfo() *ServiceSummary
func (*Receipt) ProtoMessage ¶
func (*Receipt) ProtoMessage()
func (*Receipt) XXX_DiscardUnknown ¶
func (m *Receipt) XXX_DiscardUnknown()
func (*Receipt) XXX_Marshal ¶
func (*Receipt) XXX_Unmarshal ¶
type RemoteClient ¶
type RemoteClient interface { NotifyAction(ctx context.Context, in *Action, opts ...grpc.CallOption) (*Action, error) Summary(ctx context.Context, in *Action, opts ...grpc.CallOption) (*SummaryReceipt, error) UpdateRegistration(ctx context.Context, in *ServiceUpdate, opts ...grpc.CallOption) (*Receipt, error) Alive(ctx context.Context, in *Ping, opts ...grpc.CallOption) (*Pong, error) }
RemoteClient is the client API for Remote service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRemoteClient ¶
func NewRemoteClient(cc *grpc.ClientConn) RemoteClient
type RemoteServer ¶
type RemoteServer interface { NotifyAction(context.Context, *Action) (*Action, error) Summary(context.Context, *Action) (*SummaryReceipt, error) UpdateRegistration(context.Context, *ServiceUpdate) (*Receipt, error) Alive(context.Context, *Ping) (*Pong, error) }
RemoteServer is the server API for Remote service.
type Request ¶
type Request struct { Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"` Target string `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"` Method string `protobuf:"bytes,3,opt,name=Method,proto3" json:"Method,omitempty"` Data1 string `protobuf:"bytes,50,opt,name=Data1,proto3" json:"Data1,omitempty"` Tport *Transport `protobuf:"bytes,55,opt,name=Tport,proto3" json:"Tport,omitempty"` Pload *Payload `protobuf:"bytes,60,opt,name=Pload,proto3" json:"Pload,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data Handlers
func (*Request) Descriptor ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type Responder ¶
type Responder struct { Result string `protobuf:"bytes,50,opt,name=Result,proto3" json:"Result,omitempty"` ErrorString string `protobuf:"bytes,98,opt,name=ErrorString,proto3" json:"ErrorString,omitempty"` HadError bool `protobuf:"varint,99,opt,name=HadError,proto3" json:"HadError,omitempty"` Tport *Transport `protobuf:"bytes,55,opt,name=Tport,proto3" json:"Tport,omitempty"` Pload *Payload `protobuf:"bytes,60,opt,name=Pload,proto3" json:"Pload,omitempty"` Err string `protobuf:"bytes,65,opt,name=Err,proto3" json:"Err,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Responder) Descriptor ¶
func (*Responder) GetErrorString ¶
func (*Responder) GetHadError ¶
func (*Responder) ProtoMessage ¶
func (*Responder) ProtoMessage()
func (*Responder) XXX_DiscardUnknown ¶
func (m *Responder) XXX_DiscardUnknown()
func (*Responder) XXX_Marshal ¶
func (*Responder) XXX_Unmarshal ¶
type Service ¶
type Service struct { Id string `protobuf:"bytes,10,opt,name=Id,proto3" json:"Id,omitempty"` Name string `protobuf:"bytes,11,opt,name=Name,proto3" json:"Name,omitempty"` // bool Registered = 22; Mode string `protobuf:"bytes,23,opt,name=Mode,proto3" json:"Mode,omitempty"` Address string `protobuf:"bytes,21,opt,name=Address,proto3" json:"Address,omitempty"` Path string `protobuf:"bytes,12,opt,name=Path,proto3" json:"Path,omitempty"` LogPath string `protobuf:"bytes,20,opt,name=LogPath,proto3" json:"LogPath,omitempty"` Status string `protobuf:"bytes,14,opt,name=Status,proto3" json:"Status,omitempty"` Restarts int32 `protobuf:"varint,15,opt,name=Restarts,proto3" json:"Restarts,omitempty"` Fails int32 `protobuf:"varint,24,opt,name=Fails,proto3" json:"Fails,omitempty"` Pid int32 `protobuf:"varint,16,opt,name=Pid,proto3" json:"Pid,omitempty"` StartTime string `protobuf:"bytes,17,opt,name=StartTime,proto3" json:"StartTime,omitempty"` FailTime string `protobuf:"bytes,18,opt,name=FailTime,proto3" json:"FailTime,omitempty"` Language string `protobuf:"bytes,25,opt,name=Language,proto3" json:"Language,omitempty"` Errors []string `protobuf:"bytes,19,rep,name=Errors,proto3" json:"Errors,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Service) Descriptor ¶
func (*Service) GetAddress ¶
func (*Service) GetFailTime ¶
func (*Service) GetLanguage ¶ added in v0.9.5
func (*Service) GetLogPath ¶
func (*Service) GetRestarts ¶
func (*Service) GetStartTime ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) XXX_DiscardUnknown ¶
func (m *Service) XXX_DiscardUnknown()
func (*Service) XXX_Marshal ¶
func (*Service) XXX_Unmarshal ¶
type ServiceSummary ¶
type ServiceSummary struct { Address string `protobuf:"bytes,1,opt,name=Address,proto3" json:"Address,omitempty"` ID string `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"` Fingerprint string `protobuf:"bytes,3,opt,name=Fingerprint,proto3" json:"Fingerprint,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServiceSummary) Descriptor ¶
func (*ServiceSummary) Descriptor() ([]byte, []int)
func (*ServiceSummary) GetAddress ¶
func (m *ServiceSummary) GetAddress() string
func (*ServiceSummary) GetFingerprint ¶
func (m *ServiceSummary) GetFingerprint() string
func (*ServiceSummary) GetID ¶
func (m *ServiceSummary) GetID() string
func (*ServiceSummary) ProtoMessage ¶
func (*ServiceSummary) ProtoMessage()
func (*ServiceSummary) Reset ¶
func (m *ServiceSummary) Reset()
func (*ServiceSummary) String ¶
func (m *ServiceSummary) String() string
func (*ServiceSummary) XXX_DiscardUnknown ¶
func (m *ServiceSummary) XXX_DiscardUnknown()
func (*ServiceSummary) XXX_Marshal ¶
func (m *ServiceSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceSummary) XXX_Merge ¶
func (m *ServiceSummary) XXX_Merge(src proto.Message)
func (*ServiceSummary) XXX_Size ¶
func (m *ServiceSummary) XXX_Size() int
func (*ServiceSummary) XXX_Unmarshal ¶
func (m *ServiceSummary) XXX_Unmarshal(b []byte) error
type ServiceUpdate ¶
type ServiceUpdate struct { Request string `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"` Message string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"` Address string `protobuf:"bytes,4,opt,name=Address,proto3" json:"Address,omitempty"` Env string `protobuf:"bytes,5,opt,name=Env,proto3" json:"Env,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ServiceUpdate) Descriptor ¶
func (*ServiceUpdate) Descriptor() ([]byte, []int)
func (*ServiceUpdate) GetAddress ¶ added in v0.9.5
func (m *ServiceUpdate) GetAddress() string
func (*ServiceUpdate) GetEnv ¶ added in v0.9.5
func (m *ServiceUpdate) GetEnv() string
func (*ServiceUpdate) GetError ¶
func (m *ServiceUpdate) GetError() string
func (*ServiceUpdate) GetMessage ¶
func (m *ServiceUpdate) GetMessage() string
func (*ServiceUpdate) GetRequest ¶
func (m *ServiceUpdate) GetRequest() string
func (*ServiceUpdate) ProtoMessage ¶
func (*ServiceUpdate) ProtoMessage()
func (*ServiceUpdate) Reset ¶
func (m *ServiceUpdate) Reset()
func (*ServiceUpdate) String ¶
func (m *ServiceUpdate) String() string
func (*ServiceUpdate) XXX_DiscardUnknown ¶
func (m *ServiceUpdate) XXX_DiscardUnknown()
func (*ServiceUpdate) XXX_Marshal ¶
func (m *ServiceUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServiceUpdate) XXX_Merge ¶
func (m *ServiceUpdate) XXX_Merge(src proto.Message)
func (*ServiceUpdate) XXX_Size ¶
func (m *ServiceUpdate) XXX_Size() int
func (*ServiceUpdate) XXX_Unmarshal ¶
func (m *ServiceUpdate) XXX_Unmarshal(b []byte) error
type SubFields ¶ added in v0.9.4
type SubFields struct { Sub []string `protobuf:"bytes,1,rep,name=Sub,proto3" json:"Sub,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SubFields) Descriptor ¶ added in v0.9.4
func (*SubFields) ProtoMessage ¶ added in v0.9.4
func (*SubFields) ProtoMessage()
func (*SubFields) XXX_DiscardUnknown ¶ added in v0.9.4
func (m *SubFields) XXX_DiscardUnknown()
func (*SubFields) XXX_Marshal ¶ added in v0.9.4
func (*SubFields) XXX_Unmarshal ¶ added in v0.9.4
type SummaryReceipt ¶
type SummaryReceipt struct { Remotes []*ProcessManager `protobuf:"bytes,1,rep,name=Remotes,proto3" json:"Remotes,omitempty"` Services []*CoreService `protobuf:"bytes,4,rep,name=Services,proto3" json:"Services,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SummaryReceipt) Descriptor ¶
func (*SummaryReceipt) Descriptor() ([]byte, []int)
func (*SummaryReceipt) GetError ¶
func (m *SummaryReceipt) GetError() string
func (*SummaryReceipt) GetRemotes ¶
func (m *SummaryReceipt) GetRemotes() []*ProcessManager
func (*SummaryReceipt) GetServices ¶
func (m *SummaryReceipt) GetServices() []*CoreService
func (*SummaryReceipt) ProtoMessage ¶
func (*SummaryReceipt) ProtoMessage()
func (*SummaryReceipt) Reset ¶
func (m *SummaryReceipt) Reset()
func (*SummaryReceipt) String ¶
func (m *SummaryReceipt) String() string
func (*SummaryReceipt) XXX_DiscardUnknown ¶
func (m *SummaryReceipt) XXX_DiscardUnknown()
func (*SummaryReceipt) XXX_Marshal ¶
func (m *SummaryReceipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SummaryReceipt) XXX_Merge ¶
func (m *SummaryReceipt) XXX_Merge(src proto.Message)
func (*SummaryReceipt) XXX_Size ¶
func (m *SummaryReceipt) XXX_Size() int
func (*SummaryReceipt) XXX_Unmarshal ¶
func (m *SummaryReceipt) XXX_Unmarshal(b []byte) error
type Transport ¶ added in v0.9.4
type Transport struct { Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"` Target string `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"` Method string `protobuf:"bytes,3,opt,name=Method,proto3" json:"Method,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Transport) Descriptor ¶ added in v0.9.4
func (*Transport) ProtoMessage ¶ added in v0.9.4
func (*Transport) ProtoMessage()
func (*Transport) XXX_DiscardUnknown ¶ added in v0.9.4
func (m *Transport) XXX_DiscardUnknown()
func (*Transport) XXX_Marshal ¶ added in v0.9.4
func (*Transport) XXX_Unmarshal ¶ added in v0.9.4
type WhoIsRequest ¶ added in v0.9.5
type WhoIsRequest struct { Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"` Target string `protobuf:"bytes,2,opt,name=Target,proto3" json:"Target,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WhoIsRequest) Descriptor ¶ added in v0.9.5
func (*WhoIsRequest) Descriptor() ([]byte, []int)
func (*WhoIsRequest) GetSender ¶ added in v0.9.5
func (m *WhoIsRequest) GetSender() string
func (*WhoIsRequest) GetTarget ¶ added in v0.9.5
func (m *WhoIsRequest) GetTarget() string
func (*WhoIsRequest) ProtoMessage ¶ added in v0.9.5
func (*WhoIsRequest) ProtoMessage()
func (*WhoIsRequest) Reset ¶ added in v0.9.5
func (m *WhoIsRequest) Reset()
func (*WhoIsRequest) String ¶ added in v0.9.5
func (m *WhoIsRequest) String() string
func (*WhoIsRequest) XXX_DiscardUnknown ¶ added in v0.9.5
func (m *WhoIsRequest) XXX_DiscardUnknown()
func (*WhoIsRequest) XXX_Marshal ¶ added in v0.9.5
func (m *WhoIsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WhoIsRequest) XXX_Merge ¶ added in v0.9.5
func (m *WhoIsRequest) XXX_Merge(src proto.Message)
func (*WhoIsRequest) XXX_Size ¶ added in v0.9.5
func (m *WhoIsRequest) XXX_Size() int
func (*WhoIsRequest) XXX_Unmarshal ¶ added in v0.9.5
func (m *WhoIsRequest) XXX_Unmarshal(b []byte) error
type WhoIsResponse ¶ added in v0.9.5
type WhoIsResponse struct { TargetAddress string `protobuf:"bytes,1,opt,name=TargetAddress,proto3" json:"TargetAddress,omitempty"` Error string `protobuf:"bytes,3,opt,name=Error,proto3" json:"Error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WhoIsResponse) Descriptor ¶ added in v0.9.5
func (*WhoIsResponse) Descriptor() ([]byte, []int)
func (*WhoIsResponse) GetError ¶ added in v0.9.5
func (m *WhoIsResponse) GetError() string
func (*WhoIsResponse) GetTargetAddress ¶ added in v0.9.5
func (m *WhoIsResponse) GetTargetAddress() string
func (*WhoIsResponse) ProtoMessage ¶ added in v0.9.5
func (*WhoIsResponse) ProtoMessage()
func (*WhoIsResponse) Reset ¶ added in v0.9.5
func (m *WhoIsResponse) Reset()
func (*WhoIsResponse) String ¶ added in v0.9.5
func (m *WhoIsResponse) String() string
func (*WhoIsResponse) XXX_DiscardUnknown ¶ added in v0.9.5
func (m *WhoIsResponse) XXX_DiscardUnknown()
func (*WhoIsResponse) XXX_Marshal ¶ added in v0.9.5
func (m *WhoIsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WhoIsResponse) XXX_Merge ¶ added in v0.9.5
func (m *WhoIsResponse) XXX_Merge(src proto.Message)
func (*WhoIsResponse) XXX_Size ¶ added in v0.9.5
func (m *WhoIsResponse) XXX_Size() int
func (*WhoIsResponse) XXX_Unmarshal ¶ added in v0.9.5
func (m *WhoIsResponse) XXX_Unmarshal(b []byte) error