pb

package
v0.12.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthOcc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOcc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOcc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DeviceEventType_name = map[int32]string{
	0: "NULL_DEVICE_EVENT",
	1: "END_OF_STREAM",
	2: "BASIC_TASK_TERMINATED",
}
View Source 
var DeviceEventType_value = map[string]int32{
	"NULL_DEVICE_EVENT":     0,
	"END_OF_STREAM":         1,
	"BASIC_TASK_TERMINATED": 2,
}
View Source 
var StateChangeTrigger_name = map[int32]string{
	0: "EXECUTOR",
	1: "DEVICE_INTENTIONAL",
	2: "DEVICE_ERROR",
}
View Source 
var StateChangeTrigger_value = map[string]int32{
	"EXECUTOR":           0,
	"DEVICE_INTENTIONAL": 1,
	"DEVICE_ERROR":       2,
}
View Source 
var StateType_name = map[int32]string{
	0: "STATE_STABLE",
	1: "STATE_INTERMEDIATE",
}
View Source 
var StateType_value = map[string]int32{
	"STATE_STABLE":       0,
	"STATE_INTERMEDIATE": 1,
}

Functions

func RegisterOccServer 

func RegisterOccServer(s *grpc.Server, srv OccServer)

Types

type ConfigEntry 

type ConfigEntry 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:"-"`
}

func (*ConfigEntry) Descriptor 

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

func (*ConfigEntry) GetKey 

func (m *ConfigEntry) GetKey() string

func (*ConfigEntry) GetValue 

func (m *ConfigEntry) GetValue() string

func (*ConfigEntry) Marshal 

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

func (*ConfigEntry) MarshalTo 

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

func (*ConfigEntry) MarshalToSizedBuffer added in v0.11.0 

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

func (*ConfigEntry) ProtoMessage 

func (*ConfigEntry) ProtoMessage()

func (*ConfigEntry) Reset 

func (m *ConfigEntry) Reset()

func (*ConfigEntry) Size 

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

func (*ConfigEntry) String 

func (m *ConfigEntry) String() string

func (*ConfigEntry) Unmarshal 

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

func (*ConfigEntry) XXX_DiscardUnknown 

func (m *ConfigEntry) XXX_DiscardUnknown()

func (*ConfigEntry) XXX_Marshal 

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

func (*ConfigEntry) XXX_Merge 

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

func (*ConfigEntry) XXX_Size 

func (m *ConfigEntry) XXX_Size() int

func (*ConfigEntry) XXX_Unmarshal 

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

type DeviceEvent 

type DeviceEvent struct {
	Type                 DeviceEventType `protobuf:"varint,1,opt,name=type,proto3,enum=occ_pb.DeviceEventType" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*DeviceEvent) Descriptor 

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

func (*DeviceEvent) GetType 

func (m *DeviceEvent) GetType() DeviceEventType

func (*DeviceEvent) Marshal 

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

func (*DeviceEvent) MarshalTo 

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

func (*DeviceEvent) MarshalToSizedBuffer added in v0.11.0 

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

func (*DeviceEvent) ProtoMessage 

func (*DeviceEvent) ProtoMessage()

func (*DeviceEvent) Reset 

func (m *DeviceEvent) Reset()

func (*DeviceEvent) Size 

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

func (*DeviceEvent) String 

func (m *DeviceEvent) String() string

func (*DeviceEvent) Unmarshal 

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

func (*DeviceEvent) XXX_DiscardUnknown 

func (m *DeviceEvent) XXX_DiscardUnknown()

func (*DeviceEvent) XXX_Marshal 

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

func (*DeviceEvent) XXX_Merge 

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

func (*DeviceEvent) XXX_Size 

func (m *DeviceEvent) XXX_Size() int

func (*DeviceEvent) XXX_Unmarshal 

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

type DeviceEventType 

type DeviceEventType int32
const (
	DeviceEventType_NULL_DEVICE_EVENT     DeviceEventType = 0
	DeviceEventType_END_OF_STREAM         DeviceEventType = 1
	DeviceEventType_BASIC_TASK_TERMINATED DeviceEventType = 2
)

func (DeviceEventType) EnumDescriptor 

func (DeviceEventType) EnumDescriptor() ([]byte, []int)

func (DeviceEventType) String 

func (x DeviceEventType) String() string

type EventStreamReply 

type EventStreamReply struct {
	Event                *DeviceEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*EventStreamReply) Descriptor 

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

func (*EventStreamReply) GetEvent 

func (m *EventStreamReply) GetEvent() *DeviceEvent

func (*EventStreamReply) Marshal 

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

func (*EventStreamReply) MarshalTo 

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

func (*EventStreamReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*EventStreamReply) ProtoMessage 

func (*EventStreamReply) ProtoMessage()

func (*EventStreamReply) Reset 

func (m *EventStreamReply) Reset()

func (*EventStreamReply) Size 

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

func (*EventStreamReply) String 

func (m *EventStreamReply) String() string

func (*EventStreamReply) Unmarshal 

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

func (*EventStreamReply) XXX_DiscardUnknown 

func (m *EventStreamReply) XXX_DiscardUnknown()

func (*EventStreamReply) XXX_Marshal 

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

func (*EventStreamReply) XXX_Merge 

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

func (*EventStreamReply) XXX_Size 

func (m *EventStreamReply) XXX_Size() int

func (*EventStreamReply) XXX_Unmarshal 

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

type EventStreamRequest 

type EventStreamRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventStreamRequest) Descriptor 

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

func (*EventStreamRequest) Marshal 

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

func (*EventStreamRequest) MarshalTo 

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

func (*EventStreamRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*EventStreamRequest) ProtoMessage 

func (*EventStreamRequest) ProtoMessage()

func (*EventStreamRequest) Reset 

func (m *EventStreamRequest) Reset()

func (*EventStreamRequest) Size 

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

func (*EventStreamRequest) String 

func (m *EventStreamRequest) String() string

func (*EventStreamRequest) Unmarshal 

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

func (*EventStreamRequest) XXX_DiscardUnknown 

func (m *EventStreamRequest) XXX_DiscardUnknown()

func (*EventStreamRequest) XXX_Marshal 

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

func (*EventStreamRequest) XXX_Merge 

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

func (*EventStreamRequest) XXX_Size 

func (m *EventStreamRequest) XXX_Size() int

func (*EventStreamRequest) XXX_Unmarshal 

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

type GetStateReply 

type GetStateReply struct {
	State                string   `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateReply) Descriptor 

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

func (*GetStateReply) GetState 

func (m *GetStateReply) GetState() string

func (*GetStateReply) Marshal 

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

func (*GetStateReply) MarshalTo 

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

func (*GetStateReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetStateReply) ProtoMessage 

func (*GetStateReply) ProtoMessage()

func (*GetStateReply) Reset 

func (m *GetStateReply) Reset()

func (*GetStateReply) Size 

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

func (*GetStateReply) String 

func (m *GetStateReply) String() string

func (*GetStateReply) Unmarshal 

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

func (*GetStateReply) XXX_DiscardUnknown 

func (m *GetStateReply) XXX_DiscardUnknown()

func (*GetStateReply) XXX_Marshal 

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

func (*GetStateReply) XXX_Merge 

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

func (*GetStateReply) XXX_Size 

func (m *GetStateReply) XXX_Size() int

func (*GetStateReply) XXX_Unmarshal 

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

type GetStateRequest 

type GetStateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateRequest) Descriptor 

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

func (*GetStateRequest) Marshal 

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

func (*GetStateRequest) MarshalTo 

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

func (*GetStateRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) Reset 

func (m *GetStateRequest) Reset()

func (*GetStateRequest) Size 

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

func (*GetStateRequest) String 

func (m *GetStateRequest) String() string

func (*GetStateRequest) Unmarshal 

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

func (*GetStateRequest) XXX_DiscardUnknown 

func (m *GetStateRequest) XXX_DiscardUnknown()

func (*GetStateRequest) XXX_Marshal 

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

func (*GetStateRequest) XXX_Merge 

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

func (*GetStateRequest) XXX_Size 

func (m *GetStateRequest) XXX_Size() int

func (*GetStateRequest) XXX_Unmarshal 

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

type OccClient 

type OccClient interface {
	// We have to have a notification stream because the FairMQDevice might transition
	// on its own for whatever reason.
	EventStream(ctx context.Context, in *EventStreamRequest, opts ...grpc.CallOption) (Occ_EventStreamClient, error)
	StateStream(ctx context.Context, in *StateStreamRequest, opts ...grpc.CallOption) (Occ_StateStreamClient, error)
	GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateReply, error)
	Transition(ctx context.Context, in *TransitionRequest, opts ...grpc.CallOption) (*TransitionReply, error)
}

OccClient is the client API for Occ service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewOccClient 

func NewOccClient(cc *grpc.ClientConn) OccClient

type OccServer 

type OccServer interface {
	// We have to have a notification stream because the FairMQDevice might transition
	// on its own for whatever reason.
	EventStream(*EventStreamRequest, Occ_EventStreamServer) error
	StateStream(*StateStreamRequest, Occ_StateStreamServer) error
	GetState(context.Context, *GetStateRequest) (*GetStateReply, error)
	Transition(context.Context, *TransitionRequest) (*TransitionReply, error)
}

OccServer is the server API for Occ service.

type Occ_EventStreamClient 

type Occ_EventStreamClient interface {
	Recv() (*EventStreamReply, error)
	grpc.ClientStream
}

type Occ_EventStreamServer 

type Occ_EventStreamServer interface {
	Send(*EventStreamReply) error
	grpc.ServerStream
}

type Occ_StateStreamClient 

type Occ_StateStreamClient interface {
	Recv() (*StateStreamReply, error)
	grpc.ClientStream
}

type Occ_StateStreamServer 

type Occ_StateStreamServer interface {
	Send(*StateStreamReply) error
	grpc.ServerStream
}

type StateChangeTrigger 

type StateChangeTrigger int32
const (
	StateChangeTrigger_EXECUTOR           StateChangeTrigger = 0
	StateChangeTrigger_DEVICE_INTENTIONAL StateChangeTrigger = 1
	StateChangeTrigger_DEVICE_ERROR       StateChangeTrigger = 2
)

func (StateChangeTrigger) EnumDescriptor 

func (StateChangeTrigger) EnumDescriptor() ([]byte, []int)

func (StateChangeTrigger) String 

func (x StateChangeTrigger) String() string

type StateStreamReply 

type StateStreamReply struct {
	Type                 StateType `protobuf:"varint,1,opt,name=type,proto3,enum=occ_pb.StateType" json:"type,omitempty"`
	State                string    `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*StateStreamReply) Descriptor 

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

func (*StateStreamReply) GetState 

func (m *StateStreamReply) GetState() string

func (*StateStreamReply) GetType 

func (m *StateStreamReply) GetType() StateType

func (*StateStreamReply) Marshal 

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

func (*StateStreamReply) MarshalTo 

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

func (*StateStreamReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*StateStreamReply) ProtoMessage 

func (*StateStreamReply) ProtoMessage()

func (*StateStreamReply) Reset 

func (m *StateStreamReply) Reset()

func (*StateStreamReply) Size 

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

func (*StateStreamReply) String 

func (m *StateStreamReply) String() string

func (*StateStreamReply) Unmarshal 

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

func (*StateStreamReply) XXX_DiscardUnknown 

func (m *StateStreamReply) XXX_DiscardUnknown()

func (*StateStreamReply) XXX_Marshal 

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

func (*StateStreamReply) XXX_Merge 

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

func (*StateStreamReply) XXX_Size 

func (m *StateStreamReply) XXX_Size() int

func (*StateStreamReply) XXX_Unmarshal 

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

type StateStreamRequest 

type StateStreamRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StateStreamRequest) Descriptor 

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

func (*StateStreamRequest) Marshal 

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

func (*StateStreamRequest) MarshalTo 

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

func (*StateStreamRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*StateStreamRequest) ProtoMessage 

func (*StateStreamRequest) ProtoMessage()

func (*StateStreamRequest) Reset 

func (m *StateStreamRequest) Reset()

func (*StateStreamRequest) Size 

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

func (*StateStreamRequest) String 

func (m *StateStreamRequest) String() string

func (*StateStreamRequest) Unmarshal 

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

func (*StateStreamRequest) XXX_DiscardUnknown 

func (m *StateStreamRequest) XXX_DiscardUnknown()

func (*StateStreamRequest) XXX_Marshal 

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

func (*StateStreamRequest) XXX_Merge 

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

func (*StateStreamRequest) XXX_Size 

func (m *StateStreamRequest) XXX_Size() int

func (*StateStreamRequest) XXX_Unmarshal 

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

type StateType 

type StateType int32
const (
	StateType_STATE_STABLE       StateType = 0
	StateType_STATE_INTERMEDIATE StateType = 1
)

func (StateType) EnumDescriptor 

func (StateType) EnumDescriptor() ([]byte, []int)

func (StateType) String 

func (x StateType) String() string

type TransitionReply 

type TransitionReply struct {
	Trigger              StateChangeTrigger `protobuf:"varint,1,opt,name=trigger,proto3,enum=occ_pb.StateChangeTrigger" json:"trigger,omitempty"`
	State                string             `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	TransitionEvent      string             `protobuf:"bytes,3,opt,name=transitionEvent,proto3" json:"transitionEvent,omitempty"`
	Ok                   bool               `protobuf:"varint,4,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*TransitionReply) Descriptor 

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

func (*TransitionReply) GetOk 

func (m *TransitionReply) GetOk() bool

func (*TransitionReply) GetState 

func (m *TransitionReply) GetState() string

func (*TransitionReply) GetTransitionEvent 

func (m *TransitionReply) GetTransitionEvent() string

func (*TransitionReply) GetTrigger 

func (m *TransitionReply) GetTrigger() StateChangeTrigger

func (*TransitionReply) Marshal 

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

func (*TransitionReply) MarshalTo 

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

func (*TransitionReply) MarshalToSizedBuffer added in v0.11.0 

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

func (*TransitionReply) ProtoMessage 

func (*TransitionReply) ProtoMessage()

func (*TransitionReply) Reset 

func (m *TransitionReply) Reset()

func (*TransitionReply) Size 

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

func (*TransitionReply) String 

func (m *TransitionReply) String() string

func (*TransitionReply) Unmarshal 

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

func (*TransitionReply) XXX_DiscardUnknown 

func (m *TransitionReply) XXX_DiscardUnknown()

func (*TransitionReply) XXX_Marshal 

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

func (*TransitionReply) XXX_Merge 

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

func (*TransitionReply) XXX_Size 

func (m *TransitionReply) XXX_Size() int

func (*TransitionReply) XXX_Unmarshal 

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

type TransitionRequest 

type TransitionRequest struct {
	SrcState             string         `protobuf:"bytes,1,opt,name=srcState,proto3" json:"srcState,omitempty"`
	TransitionEvent      string         `protobuf:"bytes,2,opt,name=transitionEvent,proto3" json:"transitionEvent,omitempty"`
	Arguments            []*ConfigEntry `protobuf:"bytes,3,rep,name=arguments,proto3" json:"arguments,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TransitionRequest) Descriptor 

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

func (*TransitionRequest) GetArguments 

func (m *TransitionRequest) GetArguments() []*ConfigEntry

func (*TransitionRequest) GetSrcState 

func (m *TransitionRequest) GetSrcState() string

func (*TransitionRequest) GetTransitionEvent 

func (m *TransitionRequest) GetTransitionEvent() string

func (*TransitionRequest) Marshal 

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

func (*TransitionRequest) MarshalTo 

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

func (*TransitionRequest) MarshalToSizedBuffer added in v0.11.0 

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

func (*TransitionRequest) ProtoMessage 

func (*TransitionRequest) ProtoMessage()

func (*TransitionRequest) Reset 

func (m *TransitionRequest) Reset()

func (*TransitionRequest) Size 

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

func (*TransitionRequest) String 

func (m *TransitionRequest) String() string

func (*TransitionRequest) Unmarshal 

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

func (*TransitionRequest) XXX_DiscardUnknown 

func (m *TransitionRequest) XXX_DiscardUnknown()

func (*TransitionRequest) XXX_Marshal 

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

func (*TransitionRequest) XXX_Merge 

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

func (*TransitionRequest) XXX_Size 

func (m *TransitionRequest) XXX_Size() int

func (*TransitionRequest) XXX_Unmarshal 

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

type UnimplementedOccServer added in v0.11.0 

type UnimplementedOccServer struct {
}

UnimplementedOccServer can be embedded to have forward compatible implementations.

func (*UnimplementedOccServer) EventStream added in v0.11.0 

func (*UnimplementedOccServer) EventStream(req *EventStreamRequest, srv Occ_EventStreamServer) error

func (*UnimplementedOccServer) GetState added in v0.11.0 

func (*UnimplementedOccServer) GetState(ctx context.Context, req *GetStateRequest) (*GetStateReply, error)

func (*UnimplementedOccServer) StateStream added in v0.11.0 

func (*UnimplementedOccServer) StateStream(req *StateStreamRequest, srv Occ_StateStreamServer) error

func (*UnimplementedOccServer) Transition added in v0.11.0 

func (*UnimplementedOccServer) Transition(ctx context.Context, req *TransitionRequest) (*TransitionReply, 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.