pb

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StateChangeTrigger_name = map[int32]string{
		0: "EXECUTOR",
		1: "DEVICE_INTENTIONAL",
		2: "DEVICE_ERROR",
	}
	StateChangeTrigger_value = map[string]int32{
		"EXECUTOR":           0,
		"DEVICE_INTENTIONAL": 1,
		"DEVICE_ERROR":       2,
	}
)

Enum value maps for StateChangeTrigger.

View Source 
var (
	StateType_name = map[int32]string{
		0: "STATE_STABLE",
		1: "STATE_INTERMEDIATE",
	}
	StateType_value = map[string]int32{
		"STATE_STABLE":       0,
		"STATE_INTERMEDIATE": 1,
	}
)

Enum value maps for StateType.

View Source 
var (
	DeviceEventType_name = map[int32]string{
		0: "NULL_DEVICE_EVENT",
		1: "END_OF_STREAM",
		2: "BASIC_TASK_TERMINATED",
		3: "TASK_INTERNAL_ERROR",
	}
	DeviceEventType_value = map[string]int32{
		"NULL_DEVICE_EVENT":     0,
		"END_OF_STREAM":         1,
		"BASIC_TASK_TERMINATED": 2,
		"TASK_INTERNAL_ERROR":   3,
	}
)

Enum value maps for DeviceEventType.

View Source 
var File_protos_occ_proto protoreflect.FileDescriptor
View Source 
var Occ_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "occ_pb.Occ",
	HandlerType: (*OccServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetState",
			Handler:    _Occ_GetState_Handler,
		},
		{
			MethodName: "Transition",
			Handler:    _Occ_Transition_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "EventStream",
			Handler:       _Occ_EventStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StateStream",
			Handler:       _Occ_StateStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "protos/occ.proto",
}

Occ_ServiceDesc is the grpc.ServiceDesc for Occ service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOccServer 

func RegisterOccServer(s grpc.ServiceRegistrar, 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"`
	// contains filtered or unexported fields
}

func (*ConfigEntry) Descriptor deprecated 

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

Deprecated: Use ConfigEntry.ProtoReflect.Descriptor instead.

func (*ConfigEntry) GetKey 

func (x *ConfigEntry) GetKey() string

func (*ConfigEntry) GetValue 

func (x *ConfigEntry) GetValue() string

func (*ConfigEntry) ProtoMessage 

func (*ConfigEntry) ProtoMessage()

func (*ConfigEntry) ProtoReflect added in v0.19.90 

func (x *ConfigEntry) ProtoReflect() protoreflect.Message

func (*ConfigEntry) Reset 

func (x *ConfigEntry) Reset()

func (*ConfigEntry) String 

func (x *ConfigEntry) String() string

type DeviceEvent 

type DeviceEvent struct {
	Type DeviceEventType `protobuf:"varint,1,opt,name=type,proto3,enum=occ_pb.DeviceEventType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceEvent) Descriptor deprecated 

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

Deprecated: Use DeviceEvent.ProtoReflect.Descriptor instead.

func (*DeviceEvent) GetType 

func (x *DeviceEvent) GetType() DeviceEventType

func (*DeviceEvent) ProtoMessage 

func (*DeviceEvent) ProtoMessage()

func (*DeviceEvent) ProtoReflect added in v0.19.90 

func (x *DeviceEvent) ProtoReflect() protoreflect.Message

func (*DeviceEvent) Reset 

func (x *DeviceEvent) Reset()

func (*DeviceEvent) String 

func (x *DeviceEvent) String() string

type DeviceEventType 

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

func (DeviceEventType) Descriptor added in v0.19.90 

func (DeviceEventType) Descriptor() protoreflect.EnumDescriptor

func (DeviceEventType) Enum added in v0.19.90 

func (x DeviceEventType) Enum() *DeviceEventType

func (DeviceEventType) EnumDescriptor deprecated 

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

Deprecated: Use DeviceEventType.Descriptor instead.

func (DeviceEventType) Number added in v0.19.90 

func (x DeviceEventType) Number() protoreflect.EnumNumber

func (DeviceEventType) String 

func (x DeviceEventType) String() string

func (DeviceEventType) Type added in v0.19.90 

func (DeviceEventType) Type() protoreflect.EnumType

type EventStreamReply 

type EventStreamReply struct {
	Event *DeviceEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*EventStreamReply) Descriptor deprecated 

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

Deprecated: Use EventStreamReply.ProtoReflect.Descriptor instead.

func (*EventStreamReply) GetEvent 

func (x *EventStreamReply) GetEvent() *DeviceEvent

func (*EventStreamReply) ProtoMessage 

func (*EventStreamReply) ProtoMessage()

func (*EventStreamReply) ProtoReflect added in v0.19.90 

func (x *EventStreamReply) ProtoReflect() protoreflect.Message

func (*EventStreamReply) Reset 

func (x *EventStreamReply) Reset()

func (*EventStreamReply) String 

func (x *EventStreamReply) String() string

type EventStreamRequest 

type EventStreamRequest struct {
	// contains filtered or unexported fields
}

func (*EventStreamRequest) Descriptor deprecated 

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

Deprecated: Use EventStreamRequest.ProtoReflect.Descriptor instead.

func (*EventStreamRequest) ProtoMessage 

func (*EventStreamRequest) ProtoMessage()

func (*EventStreamRequest) ProtoReflect added in v0.19.90 

func (x *EventStreamRequest) ProtoReflect() protoreflect.Message

func (*EventStreamRequest) Reset 

func (x *EventStreamRequest) Reset()

func (*EventStreamRequest) String 

func (x *EventStreamRequest) String() string

type GetStateReply 

type GetStateReply struct {
	State string `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	Pid   int32  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateReply) Descriptor deprecated 

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

Deprecated: Use GetStateReply.ProtoReflect.Descriptor instead.

func (*GetStateReply) GetPid added in v0.14.90 

func (x *GetStateReply) GetPid() int32

func (*GetStateReply) GetState 

func (x *GetStateReply) GetState() string

func (*GetStateReply) ProtoMessage 

func (*GetStateReply) ProtoMessage()

func (*GetStateReply) ProtoReflect added in v0.19.90 

func (x *GetStateReply) ProtoReflect() protoreflect.Message

func (*GetStateReply) Reset 

func (x *GetStateReply) Reset()

func (*GetStateReply) String 

func (x *GetStateReply) String() string

type GetStateRequest 

type GetStateRequest struct {
	// contains filtered or unexported fields
}

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect added in v0.19.90 

func (x *GetStateRequest) ProtoReflect() protoreflect.Message

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOccClient 

func NewOccClient(cc grpc.ClientConnInterface) 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)
	// contains filtered or unexported methods
}

OccServer is the server API for Occ service. All implementations must embed UnimplementedOccServer for forward compatibility

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) Descriptor added in v0.19.90 

func (StateChangeTrigger) Descriptor() protoreflect.EnumDescriptor

func (StateChangeTrigger) Enum added in v0.19.90 

func (x StateChangeTrigger) Enum() *StateChangeTrigger

func (StateChangeTrigger) EnumDescriptor deprecated 

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

Deprecated: Use StateChangeTrigger.Descriptor instead.

func (StateChangeTrigger) Number added in v0.19.90 

func (x StateChangeTrigger) Number() protoreflect.EnumNumber

func (StateChangeTrigger) String 

func (x StateChangeTrigger) String() string

func (StateChangeTrigger) Type added in v0.19.90 

func (StateChangeTrigger) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*StateStreamReply) Descriptor deprecated 

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

Deprecated: Use StateStreamReply.ProtoReflect.Descriptor instead.

func (*StateStreamReply) GetState 

func (x *StateStreamReply) GetState() string

func (*StateStreamReply) GetType 

func (x *StateStreamReply) GetType() StateType

func (*StateStreamReply) ProtoMessage 

func (*StateStreamReply) ProtoMessage()

func (*StateStreamReply) ProtoReflect added in v0.19.90 

func (x *StateStreamReply) ProtoReflect() protoreflect.Message

func (*StateStreamReply) Reset 

func (x *StateStreamReply) Reset()

func (*StateStreamReply) String 

func (x *StateStreamReply) String() string

type StateStreamRequest 

type StateStreamRequest struct {
	// contains filtered or unexported fields
}

func (*StateStreamRequest) Descriptor deprecated 

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

Deprecated: Use StateStreamRequest.ProtoReflect.Descriptor instead.

func (*StateStreamRequest) ProtoMessage 

func (*StateStreamRequest) ProtoMessage()

func (*StateStreamRequest) ProtoReflect added in v0.19.90 

func (x *StateStreamRequest) ProtoReflect() protoreflect.Message

func (*StateStreamRequest) Reset 

func (x *StateStreamRequest) Reset()

func (*StateStreamRequest) String 

func (x *StateStreamRequest) String() string

type StateType 

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

func (StateType) Descriptor added in v0.19.90 

func (StateType) Descriptor() protoreflect.EnumDescriptor

func (StateType) Enum added in v0.19.90 

func (x StateType) Enum() *StateType

func (StateType) EnumDescriptor deprecated 

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

Deprecated: Use StateType.Descriptor instead.

func (StateType) Number added in v0.19.90 

func (x StateType) Number() protoreflect.EnumNumber

func (StateType) String 

func (x StateType) String() string

func (StateType) Type added in v0.19.90 

func (StateType) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*TransitionReply) Descriptor deprecated 

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

Deprecated: Use TransitionReply.ProtoReflect.Descriptor instead.

func (*TransitionReply) GetOk 

func (x *TransitionReply) GetOk() bool

func (*TransitionReply) GetState 

func (x *TransitionReply) GetState() string

func (*TransitionReply) GetTransitionEvent 

func (x *TransitionReply) GetTransitionEvent() string

func (*TransitionReply) GetTrigger 

func (x *TransitionReply) GetTrigger() StateChangeTrigger

func (*TransitionReply) ProtoMessage 

func (*TransitionReply) ProtoMessage()

func (*TransitionReply) ProtoReflect added in v0.19.90 

func (x *TransitionReply) ProtoReflect() protoreflect.Message

func (*TransitionReply) Reset 

func (x *TransitionReply) Reset()

func (*TransitionReply) String 

func (x *TransitionReply) String() string

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"`
	// contains filtered or unexported fields
}

func (*TransitionRequest) Descriptor deprecated 

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

Deprecated: Use TransitionRequest.ProtoReflect.Descriptor instead.

func (*TransitionRequest) GetArguments 

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

func (*TransitionRequest) GetSrcState 

func (x *TransitionRequest) GetSrcState() string

func (*TransitionRequest) GetTransitionEvent 

func (x *TransitionRequest) GetTransitionEvent() string

func (*TransitionRequest) ProtoMessage 

func (*TransitionRequest) ProtoMessage()

func (*TransitionRequest) ProtoReflect added in v0.19.90 

func (x *TransitionRequest) ProtoReflect() protoreflect.Message

func (*TransitionRequest) Reset 

func (x *TransitionRequest) Reset()

func (*TransitionRequest) String 

func (x *TransitionRequest) String() string

type UnimplementedOccServer added in v0.11.0 

type UnimplementedOccServer struct {
}

UnimplementedOccServer must be embedded to have forward compatible implementations.

func (UnimplementedOccServer) EventStream added in v0.11.0 

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

func (UnimplementedOccServer) GetState added in v0.11.0 

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

func (UnimplementedOccServer) StateStream added in v0.11.0 

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

func (UnimplementedOccServer) Transition added in v0.11.0 

func (UnimplementedOccServer) Transition(context.Context, *TransitionRequest) (*TransitionReply, error)

type UnsafeOccServer added in v0.19.90 

type UnsafeOccServer interface {
	// contains filtered or unexported methods
}

UnsafeOccServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OccServer will result in compilation errors.

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.