intrigue

package
v0.9.6 Latest Latest
Warning

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

Go to latest
Published: Apr 15, 2019 License: MIT Imports: 6 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*Action) GetError

func (m *Action) GetError() string

func (*Action) GetMessage

func (m *Action) GetMessage() string

func (*Action) GetRemoteID

func (m *Action) GetRemoteID() string

func (*Action) GetRequest

func (m *Action) GetRequest() string

func (*Action) GetTarget

func (m *Action) GetTarget() string

func (*Action) ProtoMessage

func (*Action) ProtoMessage()

func (*Action) Reset

func (m *Action) Reset()

func (*Action) String

func (m *Action) String() string

func (*Action) XXX_DiscardUnknown

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal

func (m *Action) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Action) XXX_Merge

func (m *Action) XXX_Merge(src proto.Message)

func (*Action) XXX_Size

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal

func (m *Action) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Payload) GetBoolFields added in v0.9.4

func (m *Payload) GetBoolFields() map[string]bool

func (*Payload) GetByteFields added in v0.9.4

func (m *Payload) GetByteFields() map[string][]byte

func (*Payload) GetData added in v0.9.6

func (m *Payload) GetData() map[string]*any.Any

func (*Payload) GetDoubleFields added in v0.9.4

func (m *Payload) GetDoubleFields() map[string]float64

func (*Payload) GetFields added in v0.9.4

func (m *Payload) GetFields() map[string]*SubFields

func (*Payload) GetFloatFields added in v0.9.4

func (m *Payload) GetFloatFields() map[string]float32

func (*Payload) GetInt64Fields added in v0.9.4

func (m *Payload) GetInt64Fields() map[string]int64

func (*Payload) GetIntFields added in v0.9.4

func (m *Payload) GetIntFields() map[string]int32

func (*Payload) GetJSON added in v0.9.4

func (m *Payload) GetJSON() map[string][]byte

func (*Payload) GetTextFields added in v0.9.4

func (m *Payload) GetTextFields() map[string]string

func (*Payload) GetUint64Fields added in v0.9.4

func (m *Payload) GetUint64Fields() map[string]uint64

func (*Payload) GetUintFields added in v0.9.4

func (m *Payload) GetUintFields() map[string]uint32

func (*Payload) ProtoMessage added in v0.9.4

func (*Payload) ProtoMessage()

func (*Payload) Reset added in v0.9.4

func (m *Payload) Reset()

func (*Payload) String added in v0.9.4

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown added in v0.9.4

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal added in v0.9.4

func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Payload) XXX_Merge added in v0.9.4

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size added in v0.9.4

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal added in v0.9.4

func (m *Payload) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Ping) GetError

func (m *Ping) GetError() string

func (*Ping) GetStatus

func (m *Ping) GetStatus() string

func (*Ping) GetTime

func (m *Ping) GetTime() string

func (*Ping) ProtoMessage

func (*Ping) ProtoMessage()

func (*Ping) Reset

func (m *Ping) Reset()

func (*Ping) String

func (m *Ping) String() string

func (*Ping) XXX_DiscardUnknown

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge

func (m *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal

func (m *Ping) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Pong) GetError

func (m *Pong) GetError() string

func (*Pong) GetStatus

func (m *Pong) GetStatus() string

func (*Pong) GetTime

func (m *Pong) GetTime() string

func (*Pong) ProtoMessage

func (*Pong) ProtoMessage()

func (*Pong) Reset

func (m *Pong) Reset()

func (*Pong) String

func (m *Pong) String() string

func (*Pong) XXX_DiscardUnknown

func (m *Pong) XXX_DiscardUnknown()

func (*Pong) XXX_Marshal

func (m *Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pong) XXX_Merge

func (m *Pong) XXX_Merge(src proto.Message)

func (*Pong) XXX_Size

func (m *Pong) XXX_Size() int

func (*Pong) XXX_Unmarshal

func (m *Pong) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Receipt) GetError

func (m *Receipt) GetError() string

func (*Receipt) GetFollowup

func (m *Receipt) GetFollowup() string

func (*Receipt) GetMessage

func (m *Receipt) GetMessage() string

func (*Receipt) GetServiceInfo

func (m *Receipt) GetServiceInfo() *ServiceSummary

func (*Receipt) ProtoMessage

func (*Receipt) ProtoMessage()

func (*Receipt) Reset

func (m *Receipt) Reset()

func (*Receipt) String

func (m *Receipt) String() string

func (*Receipt) XXX_DiscardUnknown

func (m *Receipt) XXX_DiscardUnknown()

func (*Receipt) XXX_Marshal

func (m *Receipt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Receipt) XXX_Merge

func (m *Receipt) XXX_Merge(src proto.Message)

func (*Receipt) XXX_Size

func (m *Receipt) XXX_Size() int

func (*Receipt) XXX_Unmarshal

func (m *Receipt) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Request) GetData1

func (m *Request) GetData1() string

func (*Request) GetMethod

func (m *Request) GetMethod() string

func (*Request) GetPload added in v0.9.4

func (m *Request) GetPload() *Payload

func (*Request) GetSender

func (m *Request) GetSender() string

func (*Request) GetTarget

func (m *Request) GetTarget() string

func (*Request) GetTport added in v0.9.4

func (m *Request) GetTport() *Transport

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) String

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal

func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Request) XXX_Merge

func (m *Request) XXX_Merge(src proto.Message)

func (*Request) XXX_Size

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal

func (m *Request) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Responder) GetErr added in v0.9.4

func (m *Responder) GetErr() string

func (*Responder) GetErrorString

func (m *Responder) GetErrorString() string

func (*Responder) GetHadError

func (m *Responder) GetHadError() bool

func (*Responder) GetPload added in v0.9.4

func (m *Responder) GetPload() *Payload

func (*Responder) GetResult

func (m *Responder) GetResult() string

func (*Responder) GetTport added in v0.9.4

func (m *Responder) GetTport() *Transport

func (*Responder) ProtoMessage

func (*Responder) ProtoMessage()

func (*Responder) Reset

func (m *Responder) Reset()

func (*Responder) String

func (m *Responder) String() string

func (*Responder) XXX_DiscardUnknown

func (m *Responder) XXX_DiscardUnknown()

func (*Responder) XXX_Marshal

func (m *Responder) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Responder) XXX_Merge

func (m *Responder) XXX_Merge(src proto.Message)

func (*Responder) XXX_Size

func (m *Responder) XXX_Size() int

func (*Responder) XXX_Unmarshal

func (m *Responder) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Service) GetAddress

func (m *Service) GetAddress() string

func (*Service) GetErrors

func (m *Service) GetErrors() []string

func (*Service) GetFailTime

func (m *Service) GetFailTime() string

func (*Service) GetFails

func (m *Service) GetFails() int32

func (*Service) GetId

func (m *Service) GetId() string

func (*Service) GetLanguage added in v0.9.5

func (m *Service) GetLanguage() string

func (*Service) GetLogPath

func (m *Service) GetLogPath() string

func (*Service) GetMode

func (m *Service) GetMode() string

func (*Service) GetName

func (m *Service) GetName() string

func (*Service) GetPath

func (m *Service) GetPath() string

func (*Service) GetPid

func (m *Service) GetPid() int32

func (*Service) GetRestarts

func (m *Service) GetRestarts() int32

func (*Service) GetStartTime

func (m *Service) GetStartTime() string

func (*Service) GetStatus

func (m *Service) GetStatus() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) Reset

func (m *Service) Reset()

func (*Service) String

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal

func (m *Service) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*SubFields) GetSub added in v0.9.4

func (m *SubFields) GetSub() []string

func (*SubFields) ProtoMessage added in v0.9.4

func (*SubFields) ProtoMessage()

func (*SubFields) Reset added in v0.9.4

func (m *SubFields) Reset()

func (*SubFields) String added in v0.9.4

func (m *SubFields) String() string

func (*SubFields) XXX_DiscardUnknown added in v0.9.4

func (m *SubFields) XXX_DiscardUnknown()

func (*SubFields) XXX_Marshal added in v0.9.4

func (m *SubFields) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubFields) XXX_Merge added in v0.9.4

func (m *SubFields) XXX_Merge(src proto.Message)

func (*SubFields) XXX_Size added in v0.9.4

func (m *SubFields) XXX_Size() int

func (*SubFields) XXX_Unmarshal added in v0.9.4

func (m *SubFields) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Transport) GetMethod added in v0.9.4

func (m *Transport) GetMethod() string

func (*Transport) GetSender added in v0.9.4

func (m *Transport) GetSender() string

func (*Transport) GetTarget added in v0.9.4

func (m *Transport) GetTarget() string

func (*Transport) ProtoMessage added in v0.9.4

func (*Transport) ProtoMessage()

func (*Transport) Reset added in v0.9.4

func (m *Transport) Reset()

func (*Transport) String added in v0.9.4

func (m *Transport) String() string

func (*Transport) XXX_DiscardUnknown added in v0.9.4

func (m *Transport) XXX_DiscardUnknown()

func (*Transport) XXX_Marshal added in v0.9.4

func (m *Transport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Transport) XXX_Merge added in v0.9.4

func (m *Transport) XXX_Merge(src proto.Message)

func (*Transport) XXX_Size added in v0.9.4

func (m *Transport) XXX_Size() int

func (*Transport) XXX_Unmarshal added in v0.9.4

func (m *Transport) XXX_Unmarshal(b []byte) error

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL