Documentation
¶
Index ¶
- func RegisterExecAgentServer(s *grpc.Server, srv ExecAgentServer)
- type Exec
- func (*Exec) Descriptor() ([]byte, []int)
- func (m *Exec) GetCommand() string
- func (m *Exec) GetOutput() string
- func (m *Exec) GetStatus() *common.Status
- func (*Exec) ProtoMessage()
- func (m *Exec) Reset()
- func (m *Exec) String() string
- func (m *Exec) XXX_DiscardUnknown()
- func (m *Exec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Exec) XXX_Merge(src proto.Message)
- func (m *Exec) XXX_Size() int
- func (m *Exec) XXX_Unmarshal(b []byte) error
- type ExecAgentClient
- type ExecAgentServer
- type ExecRequest
- func (*ExecRequest) Descriptor() ([]byte, []int)
- func (m *ExecRequest) GetExecs() []*Exec
- func (m *ExecRequest) GetOperationType() common.Operation
- func (*ExecRequest) ProtoMessage()
- func (m *ExecRequest) Reset()
- func (m *ExecRequest) String() string
- func (m *ExecRequest) XXX_DiscardUnknown()
- func (m *ExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecRequest) XXX_Merge(src proto.Message)
- func (m *ExecRequest) XXX_Size() int
- func (m *ExecRequest) XXX_Unmarshal(b []byte) error
- type ExecResponse
- func (*ExecResponse) Descriptor() ([]byte, []int)
- func (m *ExecResponse) GetError() string
- func (m *ExecResponse) GetExecs() []*Exec
- func (m *ExecResponse) GetResult() *wrappers.BoolValue
- func (*ExecResponse) ProtoMessage()
- func (m *ExecResponse) Reset()
- func (m *ExecResponse) String() string
- func (m *ExecResponse) XXX_DiscardUnknown()
- func (m *ExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecResponse) XXX_Merge(src proto.Message)
- func (m *ExecResponse) XXX_Size() int
- func (m *ExecResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedExecAgentServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterExecAgentServer ¶
func RegisterExecAgentServer(s *grpc.Server, srv ExecAgentServer)
Types ¶
type Exec ¶
type Exec struct {
Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
Output string `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
Status *common.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Exec) Descriptor ¶
func (*Exec) GetCommand ¶
func (*Exec) ProtoMessage ¶
func (*Exec) ProtoMessage()
func (*Exec) XXX_DiscardUnknown ¶
func (m *Exec) XXX_DiscardUnknown()
func (*Exec) XXX_Unmarshal ¶
type ExecAgentClient ¶
type ExecAgentClient interface {
Invoke(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecResponse, error)
}
ExecAgentClient is the client API for ExecAgent service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewExecAgentClient ¶
func NewExecAgentClient(cc *grpc.ClientConn) ExecAgentClient
type ExecAgentServer ¶
type ExecAgentServer interface {
Invoke(context.Context, *ExecRequest) (*ExecResponse, error)
}
ExecAgentServer is the server API for ExecAgent service.
type ExecRequest ¶
type ExecRequest struct {
Execs []*Exec `protobuf:"bytes,1,rep,name=Execs,proto3" json:"Execs,omitempty"`
OperationType common.Operation `protobuf:"varint,2,opt,name=OperationType,proto3,enum=moc.Operation" json:"OperationType,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ExecRequest) Descriptor ¶
func (*ExecRequest) Descriptor() ([]byte, []int)
func (*ExecRequest) GetExecs ¶
func (m *ExecRequest) GetExecs() []*Exec
func (*ExecRequest) GetOperationType ¶
func (m *ExecRequest) GetOperationType() common.Operation
func (*ExecRequest) ProtoMessage ¶
func (*ExecRequest) ProtoMessage()
func (*ExecRequest) Reset ¶
func (m *ExecRequest) Reset()
func (*ExecRequest) String ¶
func (m *ExecRequest) String() string
func (*ExecRequest) XXX_DiscardUnknown ¶
func (m *ExecRequest) XXX_DiscardUnknown()
func (*ExecRequest) XXX_Marshal ¶
func (m *ExecRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecRequest) XXX_Merge ¶
func (m *ExecRequest) XXX_Merge(src proto.Message)
func (*ExecRequest) XXX_Size ¶
func (m *ExecRequest) XXX_Size() int
func (*ExecRequest) XXX_Unmarshal ¶
func (m *ExecRequest) XXX_Unmarshal(b []byte) error
type ExecResponse ¶
type ExecResponse struct {
Execs []*Exec `protobuf:"bytes,1,rep,name=Execs,proto3" json:"Execs,omitempty"`
Result *wrappers.BoolValue `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,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 (*ExecResponse) Descriptor ¶
func (*ExecResponse) Descriptor() ([]byte, []int)
func (*ExecResponse) GetError ¶
func (m *ExecResponse) GetError() string
func (*ExecResponse) GetExecs ¶
func (m *ExecResponse) GetExecs() []*Exec
func (*ExecResponse) GetResult ¶
func (m *ExecResponse) GetResult() *wrappers.BoolValue
func (*ExecResponse) ProtoMessage ¶
func (*ExecResponse) ProtoMessage()
func (*ExecResponse) Reset ¶
func (m *ExecResponse) Reset()
func (*ExecResponse) String ¶
func (m *ExecResponse) String() string
func (*ExecResponse) XXX_DiscardUnknown ¶
func (m *ExecResponse) XXX_DiscardUnknown()
func (*ExecResponse) XXX_Marshal ¶
func (m *ExecResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecResponse) XXX_Merge ¶
func (m *ExecResponse) XXX_Merge(src proto.Message)
func (*ExecResponse) XXX_Size ¶
func (m *ExecResponse) XXX_Size() int
func (*ExecResponse) XXX_Unmarshal ¶
func (m *ExecResponse) XXX_Unmarshal(b []byte) error
type UnimplementedExecAgentServer ¶
type UnimplementedExecAgentServer struct {
}
UnimplementedExecAgentServer can be embedded to have forward compatible implementations.
func (*UnimplementedExecAgentServer) Invoke ¶
func (*UnimplementedExecAgentServer) Invoke(ctx context.Context, req *ExecRequest) (*ExecResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.