Documentation ¶
Index ¶
- Variables
- func RegisterODCServer(s *grpc.Server, srv ODCServer)
- type ActivateRequest
- func (*ActivateRequest) Descriptor() ([]byte, []int)
- func (m *ActivateRequest) GetPartitionid() string
- func (m *ActivateRequest) GetTopology() string
- func (m *ActivateRequest) Marshal() (dAtA []byte, err error)
- func (m *ActivateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ActivateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ActivateRequest) ProtoMessage()
- func (m *ActivateRequest) Reset()
- func (m *ActivateRequest) Size() (n int)
- func (m *ActivateRequest) String() string
- func (m *ActivateRequest) Unmarshal(dAtA []byte) error
- func (m *ActivateRequest) XXX_DiscardUnknown()
- func (m *ActivateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ActivateRequest) XXX_Merge(src proto.Message)
- func (m *ActivateRequest) XXX_Size() int
- func (m *ActivateRequest) XXX_Unmarshal(b []byte) error
- type ConfigureRequest
- func (*ConfigureRequest) Descriptor() ([]byte, []int)
- func (m *ConfigureRequest) GetRequest() *StateRequest
- func (m *ConfigureRequest) Marshal() (dAtA []byte, err error)
- func (m *ConfigureRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ConfigureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ConfigureRequest) ProtoMessage()
- func (m *ConfigureRequest) Reset()
- func (m *ConfigureRequest) Size() (n int)
- func (m *ConfigureRequest) String() string
- func (m *ConfigureRequest) Unmarshal(dAtA []byte) error
- func (m *ConfigureRequest) XXX_DiscardUnknown()
- func (m *ConfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ConfigureRequest) XXX_Merge(src proto.Message)
- func (m *ConfigureRequest) XXX_Size() int
- func (m *ConfigureRequest) XXX_Unmarshal(b []byte) error
- type Device
- func (*Device) Descriptor() ([]byte, []int)
- func (m *Device) GetId() uint64
- func (m *Device) GetPath() string
- func (m *Device) GetState() string
- func (m *Device) Marshal() (dAtA []byte, err error)
- func (m *Device) MarshalTo(dAtA []byte) (int, error)
- func (m *Device) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Device) ProtoMessage()
- func (m *Device) Reset()
- func (m *Device) Size() (n int)
- func (m *Device) String() string
- func (m *Device) Unmarshal(dAtA []byte) error
- func (m *Device) XXX_DiscardUnknown()
- func (m *Device) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Device) XXX_Merge(src proto.Message)
- func (m *Device) XXX_Size() int
- func (m *Device) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetCode() int32
- func (m *Error) GetMsg() string
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type GeneralReply
- func (*GeneralReply) Descriptor() ([]byte, []int)
- func (m *GeneralReply) GetError() *Error
- func (m *GeneralReply) GetExectime() int32
- func (m *GeneralReply) GetMsg() string
- func (m *GeneralReply) GetPartitionid() string
- func (m *GeneralReply) GetSessionid() string
- func (m *GeneralReply) GetState() string
- func (m *GeneralReply) GetStatus() ReplyStatus
- func (m *GeneralReply) Marshal() (dAtA []byte, err error)
- func (m *GeneralReply) MarshalTo(dAtA []byte) (int, error)
- func (m *GeneralReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GeneralReply) ProtoMessage()
- func (m *GeneralReply) Reset()
- func (m *GeneralReply) Size() (n int)
- func (m *GeneralReply) String() string
- func (m *GeneralReply) Unmarshal(dAtA []byte) error
- func (m *GeneralReply) XXX_DiscardUnknown()
- func (m *GeneralReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GeneralReply) XXX_Merge(src proto.Message)
- func (m *GeneralReply) XXX_Size() int
- func (m *GeneralReply) XXX_Unmarshal(b []byte) error
- type InitializeRequest
- func (*InitializeRequest) Descriptor() ([]byte, []int)
- func (m *InitializeRequest) GetPartitionid() string
- func (m *InitializeRequest) GetSessionid() string
- func (m *InitializeRequest) Marshal() (dAtA []byte, err error)
- func (m *InitializeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *InitializeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*InitializeRequest) ProtoMessage()
- func (m *InitializeRequest) Reset()
- func (m *InitializeRequest) Size() (n int)
- func (m *InitializeRequest) String() string
- func (m *InitializeRequest) Unmarshal(dAtA []byte) error
- func (m *InitializeRequest) XXX_DiscardUnknown()
- func (m *InitializeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InitializeRequest) XXX_Merge(src proto.Message)
- func (m *InitializeRequest) XXX_Size() int
- func (m *InitializeRequest) XXX_Unmarshal(b []byte) error
- type ODCClient
- type ODCServer
- type Property
- func (*Property) Descriptor() ([]byte, []int)
- func (m *Property) GetKey() string
- func (m *Property) GetValue() string
- func (m *Property) Marshal() (dAtA []byte, err error)
- func (m *Property) MarshalTo(dAtA []byte) (int, error)
- func (m *Property) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Property) ProtoMessage()
- func (m *Property) Reset()
- func (m *Property) Size() (n int)
- func (m *Property) String() string
- func (m *Property) Unmarshal(dAtA []byte) error
- func (m *Property) XXX_DiscardUnknown()
- func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Property) XXX_Merge(src proto.Message)
- func (m *Property) XXX_Size() int
- func (m *Property) XXX_Unmarshal(b []byte) error
- type ReplyStatus
- type ResetRequest
- func (*ResetRequest) Descriptor() ([]byte, []int)
- func (m *ResetRequest) GetRequest() *StateRequest
- func (m *ResetRequest) Marshal() (dAtA []byte, err error)
- func (m *ResetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ResetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResetRequest) ProtoMessage()
- func (m *ResetRequest) Reset()
- func (m *ResetRequest) Size() (n int)
- func (m *ResetRequest) String() string
- func (m *ResetRequest) Unmarshal(dAtA []byte) error
- func (m *ResetRequest) XXX_DiscardUnknown()
- func (m *ResetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResetRequest) XXX_Merge(src proto.Message)
- func (m *ResetRequest) XXX_Size() int
- func (m *ResetRequest) XXX_Unmarshal(b []byte) error
- type RunRequest
- func (*RunRequest) Descriptor() ([]byte, []int)
- func (m *RunRequest) GetPartitionid() string
- func (m *RunRequest) GetTopology() string
- func (m *RunRequest) Marshal() (dAtA []byte, err error)
- func (m *RunRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RunRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RunRequest) ProtoMessage()
- func (m *RunRequest) Reset()
- func (m *RunRequest) Size() (n int)
- func (m *RunRequest) String() string
- func (m *RunRequest) Unmarshal(dAtA []byte) error
- func (m *RunRequest) XXX_DiscardUnknown()
- func (m *RunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RunRequest) XXX_Merge(src proto.Message)
- func (m *RunRequest) XXX_Size() int
- func (m *RunRequest) XXX_Unmarshal(b []byte) error
- type SetPropertiesRequest
- func (*SetPropertiesRequest) Descriptor() ([]byte, []int)
- func (m *SetPropertiesRequest) GetPartitionid() string
- func (m *SetPropertiesRequest) GetPath() string
- func (m *SetPropertiesRequest) GetProperties() []*Property
- func (m *SetPropertiesRequest) Marshal() (dAtA []byte, err error)
- func (m *SetPropertiesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetPropertiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetPropertiesRequest) ProtoMessage()
- func (m *SetPropertiesRequest) Reset()
- func (m *SetPropertiesRequest) Size() (n int)
- func (m *SetPropertiesRequest) String() string
- func (m *SetPropertiesRequest) Unmarshal(dAtA []byte) error
- func (m *SetPropertiesRequest) XXX_DiscardUnknown()
- func (m *SetPropertiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetPropertiesRequest) XXX_Merge(src proto.Message)
- func (m *SetPropertiesRequest) XXX_Size() int
- func (m *SetPropertiesRequest) XXX_Unmarshal(b []byte) error
- type ShutdownRequest
- func (*ShutdownRequest) Descriptor() ([]byte, []int)
- func (m *ShutdownRequest) GetPartitionid() string
- func (m *ShutdownRequest) Marshal() (dAtA []byte, err error)
- func (m *ShutdownRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ShutdownRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ShutdownRequest) ProtoMessage()
- func (m *ShutdownRequest) Reset()
- func (m *ShutdownRequest) Size() (n int)
- func (m *ShutdownRequest) String() string
- func (m *ShutdownRequest) Unmarshal(dAtA []byte) error
- func (m *ShutdownRequest) XXX_DiscardUnknown()
- func (m *ShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ShutdownRequest) XXX_Merge(src proto.Message)
- func (m *ShutdownRequest) XXX_Size() int
- func (m *ShutdownRequest) XXX_Unmarshal(b []byte) error
- type StartRequest
- func (*StartRequest) Descriptor() ([]byte, []int)
- func (m *StartRequest) GetRequest() *StateRequest
- func (m *StartRequest) Marshal() (dAtA []byte, err error)
- func (m *StartRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StartRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StartRequest) ProtoMessage()
- func (m *StartRequest) Reset()
- func (m *StartRequest) Size() (n int)
- func (m *StartRequest) String() string
- func (m *StartRequest) Unmarshal(dAtA []byte) error
- func (m *StartRequest) XXX_DiscardUnknown()
- func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StartRequest) XXX_Merge(src proto.Message)
- func (m *StartRequest) XXX_Size() int
- func (m *StartRequest) XXX_Unmarshal(b []byte) error
- type StateReply
- func (*StateReply) Descriptor() ([]byte, []int)
- func (m *StateReply) GetDevices() []*Device
- func (m *StateReply) GetReply() *GeneralReply
- func (m *StateReply) Marshal() (dAtA []byte, err error)
- func (m *StateReply) MarshalTo(dAtA []byte) (int, error)
- func (m *StateReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StateReply) ProtoMessage()
- func (m *StateReply) Reset()
- func (m *StateReply) Size() (n int)
- func (m *StateReply) String() string
- func (m *StateReply) Unmarshal(dAtA []byte) error
- func (m *StateReply) XXX_DiscardUnknown()
- func (m *StateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateReply) XXX_Merge(src proto.Message)
- func (m *StateReply) XXX_Size() int
- func (m *StateReply) XXX_Unmarshal(b []byte) error
- type StateRequest
- func (*StateRequest) Descriptor() ([]byte, []int)
- func (m *StateRequest) GetDetailed() bool
- func (m *StateRequest) GetPartitionid() string
- func (m *StateRequest) GetPath() string
- func (m *StateRequest) Marshal() (dAtA []byte, err error)
- func (m *StateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StateRequest) ProtoMessage()
- func (m *StateRequest) Reset()
- func (m *StateRequest) Size() (n int)
- func (m *StateRequest) String() string
- func (m *StateRequest) Unmarshal(dAtA []byte) error
- func (m *StateRequest) XXX_DiscardUnknown()
- func (m *StateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StateRequest) XXX_Merge(src proto.Message)
- func (m *StateRequest) XXX_Size() int
- func (m *StateRequest) XXX_Unmarshal(b []byte) error
- type StopRequest
- func (*StopRequest) Descriptor() ([]byte, []int)
- func (m *StopRequest) GetRequest() *StateRequest
- func (m *StopRequest) Marshal() (dAtA []byte, err error)
- func (m *StopRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StopRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StopRequest) ProtoMessage()
- func (m *StopRequest) Reset()
- func (m *StopRequest) Size() (n int)
- func (m *StopRequest) String() string
- func (m *StopRequest) Unmarshal(dAtA []byte) error
- func (m *StopRequest) XXX_DiscardUnknown()
- func (m *StopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StopRequest) XXX_Merge(src proto.Message)
- func (m *StopRequest) XXX_Size() int
- func (m *StopRequest) XXX_Unmarshal(b []byte) error
- type SubmitRequest
- func (*SubmitRequest) Descriptor() ([]byte, []int)
- func (m *SubmitRequest) GetPartitionid() string
- func (m *SubmitRequest) Marshal() (dAtA []byte, err error)
- func (m *SubmitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SubmitRequest) ProtoMessage()
- func (m *SubmitRequest) Reset()
- func (m *SubmitRequest) Size() (n int)
- func (m *SubmitRequest) String() string
- func (m *SubmitRequest) Unmarshal(dAtA []byte) error
- func (m *SubmitRequest) XXX_DiscardUnknown()
- func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SubmitRequest) XXX_Merge(src proto.Message)
- func (m *SubmitRequest) XXX_Size() int
- func (m *SubmitRequest) XXX_Unmarshal(b []byte) error
- type TerminateRequest
- func (*TerminateRequest) Descriptor() ([]byte, []int)
- func (m *TerminateRequest) GetRequest() *StateRequest
- func (m *TerminateRequest) Marshal() (dAtA []byte, err error)
- func (m *TerminateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TerminateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TerminateRequest) ProtoMessage()
- func (m *TerminateRequest) Reset()
- func (m *TerminateRequest) Size() (n int)
- func (m *TerminateRequest) String() string
- func (m *TerminateRequest) Unmarshal(dAtA []byte) error
- func (m *TerminateRequest) XXX_DiscardUnknown()
- func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TerminateRequest) XXX_Merge(src proto.Message)
- func (m *TerminateRequest) XXX_Size() int
- func (m *TerminateRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedODCServer
- func (*UnimplementedODCServer) Activate(ctx context.Context, req *ActivateRequest) (*GeneralReply, error)
- func (*UnimplementedODCServer) Configure(ctx context.Context, req *ConfigureRequest) (*StateReply, error)
- func (*UnimplementedODCServer) GetState(ctx context.Context, req *StateRequest) (*StateReply, error)
- func (*UnimplementedODCServer) Initialize(ctx context.Context, req *InitializeRequest) (*GeneralReply, error)
- func (*UnimplementedODCServer) Reset(ctx context.Context, req *ResetRequest) (*StateReply, error)
- func (*UnimplementedODCServer) Run(ctx context.Context, req *RunRequest) (*GeneralReply, error)
- func (*UnimplementedODCServer) SetProperties(ctx context.Context, req *SetPropertiesRequest) (*GeneralReply, error)
- func (*UnimplementedODCServer) Shutdown(ctx context.Context, req *ShutdownRequest) (*GeneralReply, error)
- func (*UnimplementedODCServer) Start(ctx context.Context, req *StartRequest) (*StateReply, error)
- func (*UnimplementedODCServer) Stop(ctx context.Context, req *StopRequest) (*StateReply, error)
- func (*UnimplementedODCServer) Submit(ctx context.Context, req *SubmitRequest) (*GeneralReply, error)
- func (*UnimplementedODCServer) Terminate(ctx context.Context, req *TerminateRequest) (*StateReply, error)
- func (*UnimplementedODCServer) Update(ctx context.Context, req *UpdateRequest) (*GeneralReply, error)
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRequest) GetPartitionid() string
- func (m *UpdateRequest) GetTopology() string
- func (m *UpdateRequest) Marshal() (dAtA []byte, err error)
- func (m *UpdateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateRequest) ProtoMessage()
- func (m *UpdateRequest) Reset()
- func (m *UpdateRequest) Size() (n int)
- func (m *UpdateRequest) String() string
- func (m *UpdateRequest) Unmarshal(dAtA []byte) error
- func (m *UpdateRequest) XXX_DiscardUnknown()
- func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRequest) XXX_Size() int
- func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthOdc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowOdc = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupOdc = fmt.Errorf("proto: unexpected end of group") )
var ReplyStatus_name = map[int32]string{
0: "UNKNOWN",
1: "SUCCESS",
2: "ERROR",
}
var ReplyStatus_value = map[string]int32{
"UNKNOWN": 0,
"SUCCESS": 1,
"ERROR": 2,
}
Functions ¶
func RegisterODCServer ¶
Types ¶
type ActivateRequest ¶
type ActivateRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Topology string `protobuf:"bytes,2,opt,name=topology,proto3" json:"topology,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Activate request
func (*ActivateRequest) Descriptor ¶
func (*ActivateRequest) Descriptor() ([]byte, []int)
func (*ActivateRequest) GetPartitionid ¶ added in v0.17.82
func (m *ActivateRequest) GetPartitionid() string
func (*ActivateRequest) GetTopology ¶
func (m *ActivateRequest) GetTopology() string
func (*ActivateRequest) Marshal ¶
func (m *ActivateRequest) Marshal() (dAtA []byte, err error)
func (*ActivateRequest) MarshalToSizedBuffer ¶
func (m *ActivateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ActivateRequest) ProtoMessage ¶
func (*ActivateRequest) ProtoMessage()
func (*ActivateRequest) Reset ¶
func (m *ActivateRequest) Reset()
func (*ActivateRequest) Size ¶
func (m *ActivateRequest) Size() (n int)
func (*ActivateRequest) String ¶
func (m *ActivateRequest) String() string
func (*ActivateRequest) Unmarshal ¶
func (m *ActivateRequest) Unmarshal(dAtA []byte) error
func (*ActivateRequest) XXX_DiscardUnknown ¶
func (m *ActivateRequest) XXX_DiscardUnknown()
func (*ActivateRequest) XXX_Marshal ¶
func (m *ActivateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ActivateRequest) XXX_Merge ¶
func (m *ActivateRequest) XXX_Merge(src proto.Message)
func (*ActivateRequest) XXX_Size ¶
func (m *ActivateRequest) XXX_Size() int
func (*ActivateRequest) XXX_Unmarshal ¶
func (m *ActivateRequest) XXX_Unmarshal(b []byte) error
type ConfigureRequest ¶
type ConfigureRequest struct { Request *StateRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Configure request
func (*ConfigureRequest) Descriptor ¶
func (*ConfigureRequest) Descriptor() ([]byte, []int)
func (*ConfigureRequest) GetRequest ¶
func (m *ConfigureRequest) GetRequest() *StateRequest
func (*ConfigureRequest) Marshal ¶
func (m *ConfigureRequest) Marshal() (dAtA []byte, err error)
func (*ConfigureRequest) MarshalToSizedBuffer ¶
func (m *ConfigureRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigureRequest) ProtoMessage ¶
func (*ConfigureRequest) ProtoMessage()
func (*ConfigureRequest) Reset ¶
func (m *ConfigureRequest) Reset()
func (*ConfigureRequest) Size ¶
func (m *ConfigureRequest) Size() (n int)
func (*ConfigureRequest) String ¶
func (m *ConfigureRequest) String() string
func (*ConfigureRequest) Unmarshal ¶
func (m *ConfigureRequest) Unmarshal(dAtA []byte) error
func (*ConfigureRequest) XXX_DiscardUnknown ¶
func (m *ConfigureRequest) XXX_DiscardUnknown()
func (*ConfigureRequest) XXX_Marshal ¶
func (m *ConfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureRequest) XXX_Merge ¶
func (m *ConfigureRequest) XXX_Merge(src proto.Message)
func (*ConfigureRequest) XXX_Size ¶
func (m *ConfigureRequest) XXX_Size() int
func (*ConfigureRequest) XXX_Unmarshal ¶
func (m *ConfigureRequest) XXX_Unmarshal(b []byte) error
type Device ¶
type Device struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` State string `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Device information Runtime task ID and path are the same as in DDS. To get task details use DDS Topology API.
func (*Device) Descriptor ¶
func (*Device) MarshalToSizedBuffer ¶
func (*Device) ProtoMessage ¶
func (*Device) ProtoMessage()
func (*Device) XXX_DiscardUnknown ¶
func (m *Device) XXX_DiscardUnknown()
func (*Device) XXX_Marshal ¶
func (*Device) XXX_Unmarshal ¶
type Error ¶
type Error struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Code int32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
General error
func (*Error) Descriptor ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_Unmarshal ¶
type GeneralReply ¶
type GeneralReply struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Status ReplyStatus `protobuf:"varint,2,opt,name=status,proto3,enum=odc.ReplyStatus" json:"status,omitempty"` Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Exectime int32 `protobuf:"varint,4,opt,name=exectime,proto3" json:"exectime,omitempty"` Partitionid string `protobuf:"bytes,5,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Sessionid string `protobuf:"bytes,6,opt,name=sessionid,proto3" json:"sessionid,omitempty"` State string `protobuf:"bytes,7,opt,name=state,proto3" json:"state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
General reply to requests
func (*GeneralReply) Descriptor ¶
func (*GeneralReply) Descriptor() ([]byte, []int)
func (*GeneralReply) GetError ¶
func (m *GeneralReply) GetError() *Error
func (*GeneralReply) GetExectime ¶
func (m *GeneralReply) GetExectime() int32
func (*GeneralReply) GetMsg ¶
func (m *GeneralReply) GetMsg() string
func (*GeneralReply) GetPartitionid ¶ added in v0.17.82
func (m *GeneralReply) GetPartitionid() string
func (*GeneralReply) GetSessionid ¶
func (m *GeneralReply) GetSessionid() string
func (*GeneralReply) GetState ¶
func (m *GeneralReply) GetState() string
func (*GeneralReply) GetStatus ¶
func (m *GeneralReply) GetStatus() ReplyStatus
func (*GeneralReply) Marshal ¶
func (m *GeneralReply) Marshal() (dAtA []byte, err error)
func (*GeneralReply) MarshalToSizedBuffer ¶
func (m *GeneralReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GeneralReply) ProtoMessage ¶
func (*GeneralReply) ProtoMessage()
func (*GeneralReply) Reset ¶
func (m *GeneralReply) Reset()
func (*GeneralReply) Size ¶
func (m *GeneralReply) Size() (n int)
func (*GeneralReply) String ¶
func (m *GeneralReply) String() string
func (*GeneralReply) Unmarshal ¶
func (m *GeneralReply) Unmarshal(dAtA []byte) error
func (*GeneralReply) XXX_DiscardUnknown ¶
func (m *GeneralReply) XXX_DiscardUnknown()
func (*GeneralReply) XXX_Marshal ¶
func (m *GeneralReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GeneralReply) XXX_Merge ¶
func (m *GeneralReply) XXX_Merge(src proto.Message)
func (*GeneralReply) XXX_Size ¶
func (m *GeneralReply) XXX_Size() int
func (*GeneralReply) XXX_Unmarshal ¶
func (m *GeneralReply) XXX_Unmarshal(b []byte) error
type InitializeRequest ¶
type InitializeRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Sessionid string `protobuf:"bytes,2,opt,name=sessionid,proto3" json:"sessionid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Initialize request
func (*InitializeRequest) Descriptor ¶
func (*InitializeRequest) Descriptor() ([]byte, []int)
func (*InitializeRequest) GetPartitionid ¶ added in v0.17.82
func (m *InitializeRequest) GetPartitionid() string
func (*InitializeRequest) GetSessionid ¶
func (m *InitializeRequest) GetSessionid() string
func (*InitializeRequest) Marshal ¶
func (m *InitializeRequest) Marshal() (dAtA []byte, err error)
func (*InitializeRequest) MarshalTo ¶
func (m *InitializeRequest) MarshalTo(dAtA []byte) (int, error)
func (*InitializeRequest) MarshalToSizedBuffer ¶
func (m *InitializeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*InitializeRequest) ProtoMessage ¶
func (*InitializeRequest) ProtoMessage()
func (*InitializeRequest) Reset ¶
func (m *InitializeRequest) Reset()
func (*InitializeRequest) Size ¶
func (m *InitializeRequest) Size() (n int)
func (*InitializeRequest) String ¶
func (m *InitializeRequest) String() string
func (*InitializeRequest) Unmarshal ¶
func (m *InitializeRequest) Unmarshal(dAtA []byte) error
func (*InitializeRequest) XXX_DiscardUnknown ¶
func (m *InitializeRequest) XXX_DiscardUnknown()
func (*InitializeRequest) XXX_Marshal ¶
func (m *InitializeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InitializeRequest) XXX_Merge ¶
func (m *InitializeRequest) XXX_Merge(src proto.Message)
func (*InitializeRequest) XXX_Size ¶
func (m *InitializeRequest) XXX_Size() int
func (*InitializeRequest) XXX_Unmarshal ¶
func (m *InitializeRequest) XXX_Unmarshal(b []byte) error
type ODCClient ¶
type ODCClient interface { // Creates a new DDS session or attaches to an existing DDS session. Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*GeneralReply, error) // Submits DDS agents (deploys a dynamic cluster) according to a specified computing resources. // Can be called multiple times in order to submit more DDS agents (allocate more resources). Submit(ctx context.Context, in *SubmitRequest, opts ...grpc.CallOption) (*GeneralReply, error) // Activates a given topology. Activate(ctx context.Context, in *ActivateRequest, opts ...grpc.CallOption) (*GeneralReply, error) // Run request combines Initialize, Submit and Activate into a single request. // Run request always creates a new DDS session. Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*GeneralReply, error) // Updates a topology (up or down scale number of tasks or any other topology change). // It consists of 3 commands: Reset, Activate and Configure. // Can be called multiple times. Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*GeneralReply, error) // Transitions devices into Ready state. Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*StateReply, error) // Changes devices configuration. SetProperties(ctx context.Context, in *SetPropertiesRequest, opts ...grpc.CallOption) (*GeneralReply, error) // Get current aggregated state of devices. GetState(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (*StateReply, error) // Transition devices into Running state. Start(ctx context.Context, in *StartRequest, opts ...grpc.CallOption) (*StateReply, error) // Transitions devices into Ready state. Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StateReply, error) // Transitions devices into Idle state. Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*StateReply, error) // Shuts devices down via End transition. Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*StateReply, error) // Shutdown DDS session. Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*GeneralReply, error) }
ODCClient is the client API for ODC service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewODCClient ¶
func NewODCClient(cc *grpc.ClientConn) ODCClient
type ODCServer ¶
type ODCServer interface { // Creates a new DDS session or attaches to an existing DDS session. Initialize(context.Context, *InitializeRequest) (*GeneralReply, error) // Submits DDS agents (deploys a dynamic cluster) according to a specified computing resources. // Can be called multiple times in order to submit more DDS agents (allocate more resources). Submit(context.Context, *SubmitRequest) (*GeneralReply, error) // Activates a given topology. Activate(context.Context, *ActivateRequest) (*GeneralReply, error) // Run request combines Initialize, Submit and Activate into a single request. // Run request always creates a new DDS session. Run(context.Context, *RunRequest) (*GeneralReply, error) // Updates a topology (up or down scale number of tasks or any other topology change). // It consists of 3 commands: Reset, Activate and Configure. // Can be called multiple times. Update(context.Context, *UpdateRequest) (*GeneralReply, error) // Transitions devices into Ready state. Configure(context.Context, *ConfigureRequest) (*StateReply, error) // Changes devices configuration. SetProperties(context.Context, *SetPropertiesRequest) (*GeneralReply, error) // Get current aggregated state of devices. GetState(context.Context, *StateRequest) (*StateReply, error) // Transition devices into Running state. Start(context.Context, *StartRequest) (*StateReply, error) // Transitions devices into Ready state. Stop(context.Context, *StopRequest) (*StateReply, error) // Transitions devices into Idle state. Reset(context.Context, *ResetRequest) (*StateReply, error) // Shuts devices down via End transition. Terminate(context.Context, *TerminateRequest) (*StateReply, error) // Shutdown DDS session. Shutdown(context.Context, *ShutdownRequest) (*GeneralReply, error) }
ODCServer is the server API for ODC service.
type Property ¶
type Property struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Key-Value property
func (*Property) Descriptor ¶
func (*Property) MarshalToSizedBuffer ¶
func (*Property) ProtoMessage ¶
func (*Property) ProtoMessage()
func (*Property) XXX_DiscardUnknown ¶
func (m *Property) XXX_DiscardUnknown()
func (*Property) XXX_Marshal ¶
func (*Property) XXX_Unmarshal ¶
type ReplyStatus ¶
type ReplyStatus int32
Request status
const ( ReplyStatus_UNKNOWN ReplyStatus = 0 ReplyStatus_SUCCESS ReplyStatus = 1 ReplyStatus_ERROR ReplyStatus = 2 )
func (ReplyStatus) EnumDescriptor ¶
func (ReplyStatus) EnumDescriptor() ([]byte, []int)
func (ReplyStatus) String ¶
func (x ReplyStatus) String() string
type ResetRequest ¶
type ResetRequest struct { Request *StateRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Reset request
func (*ResetRequest) Descriptor ¶
func (*ResetRequest) Descriptor() ([]byte, []int)
func (*ResetRequest) GetRequest ¶
func (m *ResetRequest) GetRequest() *StateRequest
func (*ResetRequest) Marshal ¶
func (m *ResetRequest) Marshal() (dAtA []byte, err error)
func (*ResetRequest) MarshalToSizedBuffer ¶
func (m *ResetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResetRequest) ProtoMessage ¶
func (*ResetRequest) ProtoMessage()
func (*ResetRequest) Reset ¶
func (m *ResetRequest) Reset()
func (*ResetRequest) Size ¶
func (m *ResetRequest) Size() (n int)
func (*ResetRequest) String ¶
func (m *ResetRequest) String() string
func (*ResetRequest) Unmarshal ¶
func (m *ResetRequest) Unmarshal(dAtA []byte) error
func (*ResetRequest) XXX_DiscardUnknown ¶
func (m *ResetRequest) XXX_DiscardUnknown()
func (*ResetRequest) XXX_Marshal ¶
func (m *ResetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResetRequest) XXX_Merge ¶
func (m *ResetRequest) XXX_Merge(src proto.Message)
func (*ResetRequest) XXX_Size ¶
func (m *ResetRequest) XXX_Size() int
func (*ResetRequest) XXX_Unmarshal ¶
func (m *ResetRequest) XXX_Unmarshal(b []byte) error
type RunRequest ¶
type RunRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Topology string `protobuf:"bytes,2,opt,name=topology,proto3" json:"topology,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Run request
func (*RunRequest) Descriptor ¶
func (*RunRequest) Descriptor() ([]byte, []int)
func (*RunRequest) GetPartitionid ¶ added in v0.17.82
func (m *RunRequest) GetPartitionid() string
func (*RunRequest) GetTopology ¶
func (m *RunRequest) GetTopology() string
func (*RunRequest) Marshal ¶
func (m *RunRequest) Marshal() (dAtA []byte, err error)
func (*RunRequest) MarshalToSizedBuffer ¶
func (m *RunRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RunRequest) ProtoMessage ¶
func (*RunRequest) ProtoMessage()
func (*RunRequest) Reset ¶
func (m *RunRequest) Reset()
func (*RunRequest) Size ¶
func (m *RunRequest) Size() (n int)
func (*RunRequest) String ¶
func (m *RunRequest) String() string
func (*RunRequest) Unmarshal ¶
func (m *RunRequest) Unmarshal(dAtA []byte) error
func (*RunRequest) XXX_DiscardUnknown ¶
func (m *RunRequest) XXX_DiscardUnknown()
func (*RunRequest) XXX_Marshal ¶
func (m *RunRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunRequest) XXX_Merge ¶
func (m *RunRequest) XXX_Merge(src proto.Message)
func (*RunRequest) XXX_Size ¶
func (m *RunRequest) XXX_Size() int
func (*RunRequest) XXX_Unmarshal ¶
func (m *RunRequest) XXX_Unmarshal(b []byte) error
type SetPropertiesRequest ¶
type SetPropertiesRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Properties []*Property `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Set properties request
func (*SetPropertiesRequest) Descriptor ¶
func (*SetPropertiesRequest) Descriptor() ([]byte, []int)
func (*SetPropertiesRequest) GetPartitionid ¶ added in v0.17.82
func (m *SetPropertiesRequest) GetPartitionid() string
func (*SetPropertiesRequest) GetPath ¶
func (m *SetPropertiesRequest) GetPath() string
func (*SetPropertiesRequest) GetProperties ¶
func (m *SetPropertiesRequest) GetProperties() []*Property
func (*SetPropertiesRequest) Marshal ¶
func (m *SetPropertiesRequest) Marshal() (dAtA []byte, err error)
func (*SetPropertiesRequest) MarshalTo ¶
func (m *SetPropertiesRequest) MarshalTo(dAtA []byte) (int, error)
func (*SetPropertiesRequest) MarshalToSizedBuffer ¶
func (m *SetPropertiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SetPropertiesRequest) ProtoMessage ¶
func (*SetPropertiesRequest) ProtoMessage()
func (*SetPropertiesRequest) Reset ¶
func (m *SetPropertiesRequest) Reset()
func (*SetPropertiesRequest) Size ¶
func (m *SetPropertiesRequest) Size() (n int)
func (*SetPropertiesRequest) String ¶
func (m *SetPropertiesRequest) String() string
func (*SetPropertiesRequest) Unmarshal ¶
func (m *SetPropertiesRequest) Unmarshal(dAtA []byte) error
func (*SetPropertiesRequest) XXX_DiscardUnknown ¶
func (m *SetPropertiesRequest) XXX_DiscardUnknown()
func (*SetPropertiesRequest) XXX_Marshal ¶
func (m *SetPropertiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SetPropertiesRequest) XXX_Merge ¶
func (m *SetPropertiesRequest) XXX_Merge(src proto.Message)
func (*SetPropertiesRequest) XXX_Size ¶
func (m *SetPropertiesRequest) XXX_Size() int
func (*SetPropertiesRequest) XXX_Unmarshal ¶
func (m *SetPropertiesRequest) XXX_Unmarshal(b []byte) error
type ShutdownRequest ¶
type ShutdownRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Shutdown request
func (*ShutdownRequest) Descriptor ¶
func (*ShutdownRequest) Descriptor() ([]byte, []int)
func (*ShutdownRequest) GetPartitionid ¶ added in v0.17.82
func (m *ShutdownRequest) GetPartitionid() string
func (*ShutdownRequest) Marshal ¶
func (m *ShutdownRequest) Marshal() (dAtA []byte, err error)
func (*ShutdownRequest) MarshalToSizedBuffer ¶
func (m *ShutdownRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ShutdownRequest) ProtoMessage ¶
func (*ShutdownRequest) ProtoMessage()
func (*ShutdownRequest) Reset ¶
func (m *ShutdownRequest) Reset()
func (*ShutdownRequest) Size ¶
func (m *ShutdownRequest) Size() (n int)
func (*ShutdownRequest) String ¶
func (m *ShutdownRequest) String() string
func (*ShutdownRequest) Unmarshal ¶
func (m *ShutdownRequest) Unmarshal(dAtA []byte) error
func (*ShutdownRequest) XXX_DiscardUnknown ¶
func (m *ShutdownRequest) XXX_DiscardUnknown()
func (*ShutdownRequest) XXX_Marshal ¶
func (m *ShutdownRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ShutdownRequest) XXX_Merge ¶
func (m *ShutdownRequest) XXX_Merge(src proto.Message)
func (*ShutdownRequest) XXX_Size ¶
func (m *ShutdownRequest) XXX_Size() int
func (*ShutdownRequest) XXX_Unmarshal ¶
func (m *ShutdownRequest) XXX_Unmarshal(b []byte) error
type StartRequest ¶
type StartRequest struct { Request *StateRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Start request
func (*StartRequest) Descriptor ¶
func (*StartRequest) Descriptor() ([]byte, []int)
func (*StartRequest) GetRequest ¶
func (m *StartRequest) GetRequest() *StateRequest
func (*StartRequest) Marshal ¶
func (m *StartRequest) Marshal() (dAtA []byte, err error)
func (*StartRequest) MarshalToSizedBuffer ¶
func (m *StartRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StartRequest) ProtoMessage ¶
func (*StartRequest) ProtoMessage()
func (*StartRequest) Reset ¶
func (m *StartRequest) Reset()
func (*StartRequest) Size ¶
func (m *StartRequest) Size() (n int)
func (*StartRequest) String ¶
func (m *StartRequest) String() string
func (*StartRequest) Unmarshal ¶
func (m *StartRequest) Unmarshal(dAtA []byte) error
func (*StartRequest) XXX_DiscardUnknown ¶
func (m *StartRequest) XXX_DiscardUnknown()
func (*StartRequest) XXX_Marshal ¶
func (m *StartRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StartRequest) XXX_Merge ¶
func (m *StartRequest) XXX_Merge(src proto.Message)
func (*StartRequest) XXX_Size ¶
func (m *StartRequest) XXX_Size() int
func (*StartRequest) XXX_Unmarshal ¶
func (m *StartRequest) XXX_Unmarshal(b []byte) error
type StateReply ¶
type StateReply struct { Reply *GeneralReply `protobuf:"bytes,1,opt,name=reply,proto3" json:"reply,omitempty"` Devices []*Device `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Device change/get state reply
func (*StateReply) Descriptor ¶
func (*StateReply) Descriptor() ([]byte, []int)
func (*StateReply) GetDevices ¶
func (m *StateReply) GetDevices() []*Device
func (*StateReply) GetReply ¶
func (m *StateReply) GetReply() *GeneralReply
func (*StateReply) Marshal ¶
func (m *StateReply) Marshal() (dAtA []byte, err error)
func (*StateReply) MarshalToSizedBuffer ¶
func (m *StateReply) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StateReply) ProtoMessage ¶
func (*StateReply) ProtoMessage()
func (*StateReply) Reset ¶
func (m *StateReply) Reset()
func (*StateReply) Size ¶
func (m *StateReply) Size() (n int)
func (*StateReply) String ¶
func (m *StateReply) String() string
func (*StateReply) Unmarshal ¶
func (m *StateReply) Unmarshal(dAtA []byte) error
func (*StateReply) XXX_DiscardUnknown ¶
func (m *StateReply) XXX_DiscardUnknown()
func (*StateReply) XXX_Marshal ¶
func (m *StateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StateReply) XXX_Merge ¶
func (m *StateReply) XXX_Merge(src proto.Message)
func (*StateReply) XXX_Size ¶
func (m *StateReply) XXX_Size() int
func (*StateReply) XXX_Unmarshal ¶
func (m *StateReply) XXX_Unmarshal(b []byte) error
type StateRequest ¶
type StateRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` Detailed bool `protobuf:"varint,3,opt,name=detailed,proto3" json:"detailed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Device change/get state request
func (*StateRequest) Descriptor ¶
func (*StateRequest) Descriptor() ([]byte, []int)
func (*StateRequest) GetDetailed ¶
func (m *StateRequest) GetDetailed() bool
func (*StateRequest) GetPartitionid ¶ added in v0.17.82
func (m *StateRequest) GetPartitionid() string
func (*StateRequest) GetPath ¶
func (m *StateRequest) GetPath() string
func (*StateRequest) Marshal ¶
func (m *StateRequest) Marshal() (dAtA []byte, err error)
func (*StateRequest) MarshalToSizedBuffer ¶
func (m *StateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StateRequest) ProtoMessage ¶
func (*StateRequest) ProtoMessage()
func (*StateRequest) Reset ¶
func (m *StateRequest) Reset()
func (*StateRequest) Size ¶
func (m *StateRequest) Size() (n int)
func (*StateRequest) String ¶
func (m *StateRequest) String() string
func (*StateRequest) Unmarshal ¶
func (m *StateRequest) Unmarshal(dAtA []byte) error
func (*StateRequest) XXX_DiscardUnknown ¶
func (m *StateRequest) XXX_DiscardUnknown()
func (*StateRequest) XXX_Marshal ¶
func (m *StateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StateRequest) XXX_Merge ¶
func (m *StateRequest) XXX_Merge(src proto.Message)
func (*StateRequest) XXX_Size ¶
func (m *StateRequest) XXX_Size() int
func (*StateRequest) XXX_Unmarshal ¶
func (m *StateRequest) XXX_Unmarshal(b []byte) error
type StopRequest ¶
type StopRequest struct { Request *StateRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Stop request
func (*StopRequest) Descriptor ¶
func (*StopRequest) Descriptor() ([]byte, []int)
func (*StopRequest) GetRequest ¶
func (m *StopRequest) GetRequest() *StateRequest
func (*StopRequest) Marshal ¶
func (m *StopRequest) Marshal() (dAtA []byte, err error)
func (*StopRequest) MarshalToSizedBuffer ¶
func (m *StopRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StopRequest) ProtoMessage ¶
func (*StopRequest) ProtoMessage()
func (*StopRequest) Reset ¶
func (m *StopRequest) Reset()
func (*StopRequest) Size ¶
func (m *StopRequest) Size() (n int)
func (*StopRequest) String ¶
func (m *StopRequest) String() string
func (*StopRequest) Unmarshal ¶
func (m *StopRequest) Unmarshal(dAtA []byte) error
func (*StopRequest) XXX_DiscardUnknown ¶
func (m *StopRequest) XXX_DiscardUnknown()
func (*StopRequest) XXX_Marshal ¶
func (m *StopRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StopRequest) XXX_Merge ¶
func (m *StopRequest) XXX_Merge(src proto.Message)
func (*StopRequest) XXX_Size ¶
func (m *StopRequest) XXX_Size() int
func (*StopRequest) XXX_Unmarshal ¶
func (m *StopRequest) XXX_Unmarshal(b []byte) error
type SubmitRequest ¶
type SubmitRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Submit request
func (*SubmitRequest) Descriptor ¶
func (*SubmitRequest) Descriptor() ([]byte, []int)
func (*SubmitRequest) GetPartitionid ¶ added in v0.17.82
func (m *SubmitRequest) GetPartitionid() string
func (*SubmitRequest) Marshal ¶
func (m *SubmitRequest) Marshal() (dAtA []byte, err error)
func (*SubmitRequest) MarshalToSizedBuffer ¶
func (m *SubmitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SubmitRequest) ProtoMessage ¶
func (*SubmitRequest) ProtoMessage()
func (*SubmitRequest) Reset ¶
func (m *SubmitRequest) Reset()
func (*SubmitRequest) Size ¶
func (m *SubmitRequest) Size() (n int)
func (*SubmitRequest) String ¶
func (m *SubmitRequest) String() string
func (*SubmitRequest) Unmarshal ¶
func (m *SubmitRequest) Unmarshal(dAtA []byte) error
func (*SubmitRequest) XXX_DiscardUnknown ¶
func (m *SubmitRequest) XXX_DiscardUnknown()
func (*SubmitRequest) XXX_Marshal ¶
func (m *SubmitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SubmitRequest) XXX_Merge ¶
func (m *SubmitRequest) XXX_Merge(src proto.Message)
func (*SubmitRequest) XXX_Size ¶
func (m *SubmitRequest) XXX_Size() int
func (*SubmitRequest) XXX_Unmarshal ¶
func (m *SubmitRequest) XXX_Unmarshal(b []byte) error
type TerminateRequest ¶
type TerminateRequest struct { Request *StateRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Terminate request
func (*TerminateRequest) Descriptor ¶
func (*TerminateRequest) Descriptor() ([]byte, []int)
func (*TerminateRequest) GetRequest ¶
func (m *TerminateRequest) GetRequest() *StateRequest
func (*TerminateRequest) Marshal ¶
func (m *TerminateRequest) Marshal() (dAtA []byte, err error)
func (*TerminateRequest) MarshalToSizedBuffer ¶
func (m *TerminateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TerminateRequest) ProtoMessage ¶
func (*TerminateRequest) ProtoMessage()
func (*TerminateRequest) Reset ¶
func (m *TerminateRequest) Reset()
func (*TerminateRequest) Size ¶
func (m *TerminateRequest) Size() (n int)
func (*TerminateRequest) String ¶
func (m *TerminateRequest) String() string
func (*TerminateRequest) Unmarshal ¶
func (m *TerminateRequest) Unmarshal(dAtA []byte) error
func (*TerminateRequest) XXX_DiscardUnknown ¶
func (m *TerminateRequest) XXX_DiscardUnknown()
func (*TerminateRequest) XXX_Marshal ¶
func (m *TerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TerminateRequest) XXX_Merge ¶
func (m *TerminateRequest) XXX_Merge(src proto.Message)
func (*TerminateRequest) XXX_Size ¶
func (m *TerminateRequest) XXX_Size() int
func (*TerminateRequest) XXX_Unmarshal ¶
func (m *TerminateRequest) XXX_Unmarshal(b []byte) error
type UnimplementedODCServer ¶
type UnimplementedODCServer struct { }
UnimplementedODCServer can be embedded to have forward compatible implementations.
func (*UnimplementedODCServer) Activate ¶
func (*UnimplementedODCServer) Activate(ctx context.Context, req *ActivateRequest) (*GeneralReply, error)
func (*UnimplementedODCServer) Configure ¶
func (*UnimplementedODCServer) Configure(ctx context.Context, req *ConfigureRequest) (*StateReply, error)
func (*UnimplementedODCServer) GetState ¶
func (*UnimplementedODCServer) GetState(ctx context.Context, req *StateRequest) (*StateReply, error)
func (*UnimplementedODCServer) Initialize ¶
func (*UnimplementedODCServer) Initialize(ctx context.Context, req *InitializeRequest) (*GeneralReply, error)
func (*UnimplementedODCServer) Reset ¶
func (*UnimplementedODCServer) Reset(ctx context.Context, req *ResetRequest) (*StateReply, error)
func (*UnimplementedODCServer) Run ¶
func (*UnimplementedODCServer) Run(ctx context.Context, req *RunRequest) (*GeneralReply, error)
func (*UnimplementedODCServer) SetProperties ¶
func (*UnimplementedODCServer) SetProperties(ctx context.Context, req *SetPropertiesRequest) (*GeneralReply, error)
func (*UnimplementedODCServer) Shutdown ¶
func (*UnimplementedODCServer) Shutdown(ctx context.Context, req *ShutdownRequest) (*GeneralReply, error)
func (*UnimplementedODCServer) Start ¶
func (*UnimplementedODCServer) Start(ctx context.Context, req *StartRequest) (*StateReply, error)
func (*UnimplementedODCServer) Stop ¶
func (*UnimplementedODCServer) Stop(ctx context.Context, req *StopRequest) (*StateReply, error)
func (*UnimplementedODCServer) Submit ¶
func (*UnimplementedODCServer) Submit(ctx context.Context, req *SubmitRequest) (*GeneralReply, error)
func (*UnimplementedODCServer) Terminate ¶
func (*UnimplementedODCServer) Terminate(ctx context.Context, req *TerminateRequest) (*StateReply, error)
func (*UnimplementedODCServer) Update ¶
func (*UnimplementedODCServer) Update(ctx context.Context, req *UpdateRequest) (*GeneralReply, error)
type UpdateRequest ¶
type UpdateRequest struct { Partitionid string `protobuf:"bytes,1,opt,name=partitionid,proto3" json:"partitionid,omitempty"` Topology string `protobuf:"bytes,2,opt,name=topology,proto3" json:"topology,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Update request
func (*UpdateRequest) Descriptor ¶
func (*UpdateRequest) Descriptor() ([]byte, []int)
func (*UpdateRequest) GetPartitionid ¶ added in v0.17.82
func (m *UpdateRequest) GetPartitionid() string
func (*UpdateRequest) GetTopology ¶
func (m *UpdateRequest) GetTopology() string
func (*UpdateRequest) Marshal ¶
func (m *UpdateRequest) Marshal() (dAtA []byte, err error)
func (*UpdateRequest) MarshalToSizedBuffer ¶
func (m *UpdateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) Reset ¶
func (m *UpdateRequest) Reset()
func (*UpdateRequest) Size ¶
func (m *UpdateRequest) Size() (n int)
func (*UpdateRequest) String ¶
func (m *UpdateRequest) String() string
func (*UpdateRequest) Unmarshal ¶
func (m *UpdateRequest) Unmarshal(dAtA []byte) error
func (*UpdateRequest) XXX_DiscardUnknown ¶
func (m *UpdateRequest) XXX_DiscardUnknown()
func (*UpdateRequest) XXX_Marshal ¶
func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRequest) XXX_Merge ¶
func (m *UpdateRequest) XXX_Merge(src proto.Message)
func (*UpdateRequest) XXX_Size ¶
func (m *UpdateRequest) XXX_Size() int
func (*UpdateRequest) XXX_Unmarshal ¶
func (m *UpdateRequest) XXX_Unmarshal(b []byte) error