odc

package
v0.17.81 Latest Latest
Warning

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

 Go to latest Published: Nov 10, 2020 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthOdc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOdc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOdc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ReplyStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SUCCESS",
	2: "ERROR",
}
View Source 
var ReplyStatus_value = map[string]int32{
	"UNKNOWN": 0,
	"SUCCESS": 1,
	"ERROR":   2,
}

Functions

func RegisterODCServer 

func RegisterODCServer(s *grpc.Server, srv ODCServer)

Types

type ActivateRequest 

type ActivateRequest struct {
	Topology             string   `protobuf:"bytes,1,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) GetTopology 

func (m *ActivateRequest) GetTopology() string

func (*ActivateRequest) Marshal 

func (m *ActivateRequest) Marshal() (dAtA []byte, err error)

func (*ActivateRequest) MarshalTo 

func (m *ActivateRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ConfigureRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Device) GetId 

func (m *Device) GetId() uint64

func (*Device) GetPath 

func (m *Device) GetPath() string

func (*Device) GetState 

func (m *Device) GetState() string

func (*Device) Marshal 

func (m *Device) Marshal() (dAtA []byte, err error)

func (*Device) MarshalTo 

func (m *Device) MarshalTo(dAtA []byte) (int, error)

func (*Device) MarshalToSizedBuffer 

func (m *Device) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) Reset 

func (m *Device) Reset()

func (*Device) Size 

func (m *Device) Size() (n int)

func (*Device) String 

func (m *Device) String() string

func (*Device) Unmarshal 

func (m *Device) Unmarshal(dAtA []byte) error

func (*Device) XXX_DiscardUnknown 

func (m *Device) XXX_DiscardUnknown()

func (*Device) XXX_Marshal 

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

func (*Device) XXX_Merge 

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

func (*Device) XXX_Size 

func (m *Device) XXX_Size() int

func (*Device) XXX_Unmarshal 

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

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

func (*Error) GetCode 

func (m *Error) GetCode() int32

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) Marshal 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) MarshalToSizedBuffer 

func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

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"`
	Runid                uint64      `protobuf:"varint,5,opt,name=runid,proto3" json:"runid,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) GetRunid 

func (m *GeneralReply) GetRunid() uint64

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) MarshalTo 

func (m *GeneralReply) MarshalTo(dAtA []byte) (int, 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 {
	Runid                uint64   `protobuf:"varint,1,opt,name=runid,proto3" json:"runid,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) GetRunid 

func (m *InitializeRequest) GetRunid() uint64

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

func (*Property) GetKey 

func (m *Property) GetKey() string

func (*Property) GetValue 

func (m *Property) GetValue() string

func (*Property) Marshal 

func (m *Property) Marshal() (dAtA []byte, err error)

func (*Property) MarshalTo 

func (m *Property) MarshalTo(dAtA []byte) (int, error)

func (*Property) MarshalToSizedBuffer 

func (m *Property) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) Reset 

func (m *Property) Reset()

func (*Property) Size 

func (m *Property) Size() (n int)

func (*Property) String 

func (m *Property) String() string

func (*Property) Unmarshal 

func (m *Property) Unmarshal(dAtA []byte) error

func (*Property) XXX_DiscardUnknown 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal 

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

func (*Property) XXX_Merge 

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

func (*Property) XXX_Size 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal 

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

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) MarshalTo 

func (m *ResetRequest) MarshalTo(dAtA []byte) (int, 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 {
	Runid                uint64   `protobuf:"varint,1,opt,name=runid,proto3" json:"runid,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) GetRunid 

func (m *RunRequest) GetRunid() uint64

func (*RunRequest) GetTopology 

func (m *RunRequest) GetTopology() string

func (*RunRequest) Marshal 

func (m *RunRequest) Marshal() (dAtA []byte, err error)

func (*RunRequest) MarshalTo 

func (m *RunRequest) MarshalTo(dAtA []byte) (int, 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 {
	Path                 string      `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Properties           []*Property `protobuf:"bytes,2,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) 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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Shutdown request

func (*ShutdownRequest) Descriptor 

func (*ShutdownRequest) Descriptor() ([]byte, []int)

func (*ShutdownRequest) Marshal 

func (m *ShutdownRequest) Marshal() (dAtA []byte, err error)

func (*ShutdownRequest) MarshalTo 

func (m *ShutdownRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StartRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StateReply) MarshalTo(dAtA []byte) (int, 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 {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Detailed             bool     `protobuf:"varint,2,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) GetPath 

func (m *StateRequest) GetPath() string

func (*StateRequest) Marshal 

func (m *StateRequest) Marshal() (dAtA []byte, err error)

func (*StateRequest) MarshalTo 

func (m *StateRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StopRequest) MarshalTo(dAtA []byte) (int, 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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Submit request

func (*SubmitRequest) Descriptor 

func (*SubmitRequest) Descriptor() ([]byte, []int)

func (*SubmitRequest) Marshal 

func (m *SubmitRequest) Marshal() (dAtA []byte, err error)

func (*SubmitRequest) MarshalTo 

func (m *SubmitRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *TerminateRequest) MarshalTo(dAtA []byte) (int, 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 {
	Topology             string   `protobuf:"bytes,1,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) GetTopology 

func (m *UpdateRequest) GetTopology() string

func (*UpdateRequest) Marshal 

func (m *UpdateRequest) Marshal() (dAtA []byte, err error)

func (*UpdateRequest) MarshalTo 

func (m *UpdateRequest) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.