configurator

package
v5.4.100 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2023 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Configurator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "configurator.Configurator",
	HandlerType: (*ConfiguratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRadioCfg",
			Handler:    _Configurator_GetRadioCfg_Handler,
		},
		{
			MethodName: "TaskAcquire",
			Handler:    _Configurator_TaskAcquire_Handler,
		},
		{
			MethodName: "TaskDiscoveryReceived",
			Handler:    _Configurator_TaskDiscoveryReceived_Handler,
		},
		{
			MethodName: "TaskFinished",
			Handler:    _Configurator_TaskFinished_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "configurator/api.proto",
}

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

View Source 
var File_configurator_api_proto protoreflect.FileDescriptor

Functions

func RegisterConfiguratorServer 

func RegisterConfiguratorServer(s grpc.ServiceRegistrar, srv ConfiguratorServer)

Types

type ConfiguratorClient 

type ConfiguratorClient interface {
	// Return radio configuration for receiver
	GetRadioCfg(ctx context.Context, in *RadioCfgRequest, opts ...grpc.CallOption) (*RadioCfgResponse, error)
	// Sensor configuration task: Acquire
	TaskAcquire(ctx context.Context, in *Task, opts ...grpc.CallOption) (*TaskDetails, error)
	// Sensor configuration task: Discovery received
	TaskDiscoveryReceived(ctx context.Context, in *Task, opts ...grpc.CallOption) (*TaskUpdateResponse, error)
	// Sensor configuration task: finished
	TaskFinished(ctx context.Context, in *TaskFinishedRequest, opts ...grpc.CallOption) (*TaskUpdateResponse, error)
}

ConfiguratorClient is the client API for Configurator 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 NewConfiguratorClient 

func NewConfiguratorClient(cc grpc.ClientConnInterface) ConfiguratorClient

type ConfiguratorServer 

type ConfiguratorServer interface {
	// Return radio configuration for receiver
	GetRadioCfg(context.Context, *RadioCfgRequest) (*RadioCfgResponse, error)
	// Sensor configuration task: Acquire
	TaskAcquire(context.Context, *Task) (*TaskDetails, error)
	// Sensor configuration task: Discovery received
	TaskDiscoveryReceived(context.Context, *Task) (*TaskUpdateResponse, error)
	// Sensor configuration task: finished
	TaskFinished(context.Context, *TaskFinishedRequest) (*TaskUpdateResponse, error)
	// contains filtered or unexported methods
}

ConfiguratorServer is the server API for Configurator service. All implementations must embed UnimplementedConfiguratorServer for forward compatibility

func NewConfigurator 

func NewConfigurator(db *pgxpool.Pool, location *time.Location) ConfiguratorServer

NewConfigurator returns a new configurator

type RadioCfgRequest 

type RadioCfgRequest struct {
	Cluster uint32 `protobuf:"varint,1,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*RadioCfgRequest) Descriptor deprecated 

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

Deprecated: Use RadioCfgRequest.ProtoReflect.Descriptor instead.

func (*RadioCfgRequest) GetCluster 

func (x *RadioCfgRequest) GetCluster() uint32

func (*RadioCfgRequest) ProtoMessage 

func (*RadioCfgRequest) ProtoMessage()

func (*RadioCfgRequest) ProtoReflect 

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

func (*RadioCfgRequest) Reset 

func (x *RadioCfgRequest) Reset()

func (*RadioCfgRequest) String 

func (x *RadioCfgRequest) String() string

type RadioCfgResponse 

type RadioCfgResponse struct {
	Network     uint32 `protobuf:"varint,1,opt,name=network,proto3" json:"network,omitempty"`
	RadioConfig []byte `protobuf:"bytes,2,opt,name=radio_config,json=radioConfig,proto3" json:"radio_config,omitempty"`
	AesKey      []byte `protobuf:"bytes,3,opt,name=aes_key,json=aesKey,proto3" json:"aes_key,omitempty"`
	// contains filtered or unexported fields
}

func (*RadioCfgResponse) Descriptor deprecated 

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

Deprecated: Use RadioCfgResponse.ProtoReflect.Descriptor instead.

func (*RadioCfgResponse) GetAesKey 

func (x *RadioCfgResponse) GetAesKey() []byte

func (*RadioCfgResponse) GetNetwork 

func (x *RadioCfgResponse) GetNetwork() uint32

func (*RadioCfgResponse) GetRadioConfig 

func (x *RadioCfgResponse) GetRadioConfig() []byte

func (*RadioCfgResponse) ProtoMessage 

func (*RadioCfgResponse) ProtoMessage()

func (*RadioCfgResponse) ProtoReflect 

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

func (*RadioCfgResponse) Reset 

func (x *RadioCfgResponse) Reset()

func (*RadioCfgResponse) String 

func (x *RadioCfgResponse) String() string

type Task 

type Task struct {
	TaskId uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetTaskId 

func (x *Task) GetTaskId() uint32

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskDetails 

type TaskDetails struct {
	TaskId   uint32            `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	SensorId uint32            `protobuf:"varint,2,opt,name=sensor_id,json=sensorId,proto3" json:"sensor_id,omitempty"`
	Config   *RadioCfgResponse `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskDetails) Descriptor deprecated 

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

Deprecated: Use TaskDetails.ProtoReflect.Descriptor instead.

func (*TaskDetails) GetConfig 

func (x *TaskDetails) GetConfig() *RadioCfgResponse

func (*TaskDetails) GetSensorId 

func (x *TaskDetails) GetSensorId() uint32

func (*TaskDetails) GetTaskId 

func (x *TaskDetails) GetTaskId() uint32

func (*TaskDetails) ProtoMessage 

func (*TaskDetails) ProtoMessage()

func (*TaskDetails) ProtoReflect 

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

func (*TaskDetails) Reset 

func (x *TaskDetails) Reset()

func (*TaskDetails) String 

func (x *TaskDetails) String() string

type TaskFinishedRequest 

type TaskFinishedRequest struct {
	TaskId uint32 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFinishedRequest) Descriptor deprecated 

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

Deprecated: Use TaskFinishedRequest.ProtoReflect.Descriptor instead.

func (*TaskFinishedRequest) GetError 

func (x *TaskFinishedRequest) GetError() string

func (*TaskFinishedRequest) GetTaskId 

func (x *TaskFinishedRequest) GetTaskId() uint32

func (*TaskFinishedRequest) ProtoMessage 

func (*TaskFinishedRequest) ProtoMessage()

func (*TaskFinishedRequest) ProtoReflect 

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

func (*TaskFinishedRequest) Reset 

func (x *TaskFinishedRequest) Reset()

func (*TaskFinishedRequest) String 

func (x *TaskFinishedRequest) String() string

type TaskUpdateResponse 

type TaskUpdateResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskUpdateResponse) Descriptor deprecated 

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

Deprecated: Use TaskUpdateResponse.ProtoReflect.Descriptor instead.

func (*TaskUpdateResponse) GetSuccess 

func (x *TaskUpdateResponse) GetSuccess() bool

func (*TaskUpdateResponse) ProtoMessage 

func (*TaskUpdateResponse) ProtoMessage()

func (*TaskUpdateResponse) ProtoReflect 

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

func (*TaskUpdateResponse) Reset 

func (x *TaskUpdateResponse) Reset()

func (*TaskUpdateResponse) String 

func (x *TaskUpdateResponse) String() string

type UnimplementedConfiguratorServer 

type UnimplementedConfiguratorServer struct {
}

UnimplementedConfiguratorServer must be embedded to have forward compatible implementations.

func (UnimplementedConfiguratorServer) GetRadioCfg 

func (UnimplementedConfiguratorServer) GetRadioCfg(context.Context, *RadioCfgRequest) (*RadioCfgResponse, error)

func (UnimplementedConfiguratorServer) TaskAcquire 

func (UnimplementedConfiguratorServer) TaskAcquire(context.Context, *Task) (*TaskDetails, error)

func (UnimplementedConfiguratorServer) TaskDiscoveryReceived 

func (UnimplementedConfiguratorServer) TaskDiscoveryReceived(context.Context, *Task) (*TaskUpdateResponse, error)

func (UnimplementedConfiguratorServer) TaskFinished 

func (UnimplementedConfiguratorServer) TaskFinished(context.Context, *TaskFinishedRequest) (*TaskUpdateResponse, error)

type UnsafeConfiguratorServer 

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

UnsafeConfiguratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfiguratorServer 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.