admin

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
  • func NewExecAgentClient(cc *grpc.ClientConn) 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
  • func (*UnimplementedExecAgentServer) Invoke(ctx context.Context, req *ExecRequest) (*ExecResponse, error)

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

func (*Exec) GetCommand

func (m *Exec) GetCommand() string

func (*Exec) GetOutput

func (m *Exec) GetOutput() string

func (*Exec) GetStatus

func (m *Exec) GetStatus() *common.Status

func (*Exec) ProtoMessage

func (*Exec) ProtoMessage()

func (*Exec) Reset

func (m *Exec) Reset()

func (*Exec) String

func (m *Exec) String() string

func (*Exec) XXX_DiscardUnknown

func (m *Exec) XXX_DiscardUnknown()

func (*Exec) XXX_Marshal

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

func (*Exec) XXX_Merge

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

func (*Exec) XXX_Size

func (m *Exec) XXX_Size() int

func (*Exec) XXX_Unmarshal

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

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)