proto

package
v0.0.0-...-5d52b9c Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	CoordinatorControlService_GetWorkers_FullMethodName   = "/emerwen.coordinatorcontrol.CoordinatorControlService/GetWorkers"
	CoordinatorControlService_NewWorker_FullMethodName    = "/emerwen.coordinatorcontrol.CoordinatorControlService/NewWorker"
	CoordinatorControlService_PatchWorker_FullMethodName  = "/emerwen.coordinatorcontrol.CoordinatorControlService/PatchWorker"
	CoordinatorControlService_DeleteTarget_FullMethodName = "/emerwen.coordinatorcontrol.CoordinatorControlService/DeleteTarget"
	CoordinatorControlService_NewTarget_FullMethodName    = "/emerwen.coordinatorcontrol.CoordinatorControlService/NewTarget"
	CoordinatorControlService_PatchTarget_FullMethodName  = "/emerwen.coordinatorcontrol.CoordinatorControlService/PatchTarget"
	CoordinatorControlService_DeleteWorker_FullMethodName = "/emerwen.coordinatorcontrol.CoordinatorControlService/DeleteWorker"
)

Variables

View Source 
var CoordinatorControlService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "emerwen.coordinatorcontrol.CoordinatorControlService",
	HandlerType: (*CoordinatorControlServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetWorkers",
			Handler:    _CoordinatorControlService_GetWorkers_Handler,
		},
		{
			MethodName: "NewWorker",
			Handler:    _CoordinatorControlService_NewWorker_Handler,
		},
		{
			MethodName: "PatchWorker",
			Handler:    _CoordinatorControlService_PatchWorker_Handler,
		},
		{
			MethodName: "DeleteTarget",
			Handler:    _CoordinatorControlService_DeleteTarget_Handler,
		},
		{
			MethodName: "NewTarget",
			Handler:    _CoordinatorControlService_NewTarget_Handler,
		},
		{
			MethodName: "PatchTarget",
			Handler:    _CoordinatorControlService_PatchTarget_Handler,
		},
		{
			MethodName: "DeleteWorker",
			Handler:    _CoordinatorControlService_DeleteWorker_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "coordinatorcontrol.proto",
}

CoordinatorControlService_ServiceDesc is the grpc.ServiceDesc for CoordinatorControlService 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_coordinatorcontrol_proto protoreflect.FileDescriptor

Functions

func RegisterCoordinatorControlServiceServer 

func RegisterCoordinatorControlServiceServer(s grpc.ServiceRegistrar, srv CoordinatorControlServiceServer)

Types

type CoordinatorControlServiceClient 

type CoordinatorControlServiceClient interface {
	GetWorkers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*WorkersResponse, error)
	NewWorker(ctx context.Context, in *NewWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PatchWorker(ctx context.Context, in *PatchWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteTarget(ctx context.Context, in *DeleteTargetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	NewTarget(ctx context.Context, in *NewTargetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PatchTarget(ctx context.Context, in *PatchTargetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteWorker(ctx context.Context, in *DeleteWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

CoordinatorControlServiceClient is the client API for CoordinatorControlService 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 NewCoordinatorControlServiceClient 

func NewCoordinatorControlServiceClient(cc grpc.ClientConnInterface) CoordinatorControlServiceClient

type CoordinatorControlServiceServer 

type CoordinatorControlServiceServer interface {
	GetWorkers(context.Context, *emptypb.Empty) (*WorkersResponse, error)
	NewWorker(context.Context, *NewWorkerRequest) (*emptypb.Empty, error)
	PatchWorker(context.Context, *PatchWorkerRequest) (*emptypb.Empty, error)
	DeleteTarget(context.Context, *DeleteTargetRequest) (*emptypb.Empty, error)
	NewTarget(context.Context, *NewTargetRequest) (*emptypb.Empty, error)
	PatchTarget(context.Context, *PatchTargetRequest) (*emptypb.Empty, error)
	DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

CoordinatorControlServiceServer is the server API for CoordinatorControlService service. All implementations must embed UnimplementedCoordinatorControlServiceServer for forward compatibility

type DeleteTargetRequest 

type DeleteTargetRequest struct {
	TargetId string `protobuf:"bytes,1,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTargetRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTargetRequest.ProtoReflect.Descriptor instead.

func (*DeleteTargetRequest) GetTargetId 

func (x *DeleteTargetRequest) GetTargetId() string

func (*DeleteTargetRequest) ProtoMessage 

func (*DeleteTargetRequest) ProtoMessage()

func (*DeleteTargetRequest) ProtoReflect 

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

func (*DeleteTargetRequest) Reset 

func (x *DeleteTargetRequest) Reset()

func (*DeleteTargetRequest) String 

func (x *DeleteTargetRequest) String() string

type DeleteWorkerRequest 

type DeleteWorkerRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkerRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWorkerRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkerRequest) GetWorkerId 

func (x *DeleteWorkerRequest) GetWorkerId() string

func (*DeleteWorkerRequest) ProtoMessage 

func (*DeleteWorkerRequest) ProtoMessage()

func (*DeleteWorkerRequest) ProtoReflect 

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

func (*DeleteWorkerRequest) Reset 

func (x *DeleteWorkerRequest) Reset()

func (*DeleteWorkerRequest) String 

func (x *DeleteWorkerRequest) String() string

type NewTargetRequest 

type NewTargetRequest struct {
	WorkerId string        `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Name     string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Addr     string        `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Interval int32         `protobuf:"varint,4,opt,name=interval,proto3" json:"interval,omitempty"`
	Method   shared.Method `protobuf:"varint,5,opt,name=method,proto3,enum=emerwen.shared.Method" json:"method,omitempty"`
	OkCodes  []int32       `protobuf:"varint,6,rep,packed,name=ok_codes,json=okCodes,proto3" json:"ok_codes,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTargetRequest) Descriptor deprecated 

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

Deprecated: Use NewTargetRequest.ProtoReflect.Descriptor instead.

func (*NewTargetRequest) GetAddr 

func (x *NewTargetRequest) GetAddr() string

func (*NewTargetRequest) GetInterval 

func (x *NewTargetRequest) GetInterval() int32

func (*NewTargetRequest) GetMethod 

func (x *NewTargetRequest) GetMethod() shared.Method

func (*NewTargetRequest) GetName 

func (x *NewTargetRequest) GetName() string

func (*NewTargetRequest) GetOkCodes 

func (x *NewTargetRequest) GetOkCodes() []int32

func (*NewTargetRequest) GetWorkerId 

func (x *NewTargetRequest) GetWorkerId() string

func (*NewTargetRequest) ProtoMessage 

func (*NewTargetRequest) ProtoMessage()

func (*NewTargetRequest) ProtoReflect 

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

func (*NewTargetRequest) Reset 

func (x *NewTargetRequest) Reset()

func (*NewTargetRequest) String 

func (x *NewTargetRequest) String() string

type NewWorkerRequest 

type NewWorkerRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*NewWorkerRequest) Descriptor deprecated 

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

Deprecated: Use NewWorkerRequest.ProtoReflect.Descriptor instead.

func (*NewWorkerRequest) GetName 

func (x *NewWorkerRequest) GetName() string

func (*NewWorkerRequest) ProtoMessage 

func (*NewWorkerRequest) ProtoMessage()

func (*NewWorkerRequest) ProtoReflect 

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

func (*NewWorkerRequest) Reset 

func (x *NewWorkerRequest) Reset()

func (*NewWorkerRequest) String 

func (x *NewWorkerRequest) String() string

type PatchTargetRequest 

type PatchTargetRequest struct {
	TargetId string         `protobuf:"bytes,1,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	Name     *string        `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Addr     *string        `protobuf:"bytes,3,opt,name=addr,proto3,oneof" json:"addr,omitempty"`
	Interval *int32         `protobuf:"varint,4,opt,name=interval,proto3,oneof" json:"interval,omitempty"`
	Method   *shared.Method `protobuf:"varint,5,opt,name=method,proto3,enum=emerwen.shared.Method,oneof" json:"method,omitempty"`
	OkCodes  []int32        `protobuf:"varint,6,rep,packed,name=ok_codes,json=okCodes,proto3" json:"ok_codes,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchTargetRequest) Descriptor deprecated 

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

Deprecated: Use PatchTargetRequest.ProtoReflect.Descriptor instead.

func (*PatchTargetRequest) GetAddr 

func (x *PatchTargetRequest) GetAddr() string

func (*PatchTargetRequest) GetInterval 

func (x *PatchTargetRequest) GetInterval() int32

func (*PatchTargetRequest) GetMethod 

func (x *PatchTargetRequest) GetMethod() shared.Method

func (*PatchTargetRequest) GetName 

func (x *PatchTargetRequest) GetName() string

func (*PatchTargetRequest) GetOkCodes 

func (x *PatchTargetRequest) GetOkCodes() []int32

func (*PatchTargetRequest) GetTargetId 

func (x *PatchTargetRequest) GetTargetId() string

func (*PatchTargetRequest) ProtoMessage 

func (*PatchTargetRequest) ProtoMessage()

func (*PatchTargetRequest) ProtoReflect 

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

func (*PatchTargetRequest) Reset 

func (x *PatchTargetRequest) Reset()

func (*PatchTargetRequest) String 

func (x *PatchTargetRequest) String() string

type PatchWorkerRequest 

type PatchWorkerRequest struct {
	WorkerId string  `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Name     *string `protobuf:"bytes,2,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchWorkerRequest) Descriptor deprecated 

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

Deprecated: Use PatchWorkerRequest.ProtoReflect.Descriptor instead.

func (*PatchWorkerRequest) GetName 

func (x *PatchWorkerRequest) GetName() string

func (*PatchWorkerRequest) GetWorkerId 

func (x *PatchWorkerRequest) GetWorkerId() string

func (*PatchWorkerRequest) ProtoMessage 

func (*PatchWorkerRequest) ProtoMessage()

func (*PatchWorkerRequest) ProtoReflect 

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

func (*PatchWorkerRequest) Reset 

func (x *PatchWorkerRequest) Reset()

func (*PatchWorkerRequest) String 

func (x *PatchWorkerRequest) String() string

type UnimplementedCoordinatorControlServiceServer 

type UnimplementedCoordinatorControlServiceServer struct {
}

UnimplementedCoordinatorControlServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCoordinatorControlServiceServer) DeleteTarget 

func (UnimplementedCoordinatorControlServiceServer) DeleteTarget(context.Context, *DeleteTargetRequest) (*emptypb.Empty, error)

func (UnimplementedCoordinatorControlServiceServer) DeleteWorker 

func (UnimplementedCoordinatorControlServiceServer) DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)

func (UnimplementedCoordinatorControlServiceServer) GetWorkers 

func (UnimplementedCoordinatorControlServiceServer) GetWorkers(context.Context, *emptypb.Empty) (*WorkersResponse, error)

func (UnimplementedCoordinatorControlServiceServer) NewTarget 

func (UnimplementedCoordinatorControlServiceServer) NewTarget(context.Context, *NewTargetRequest) (*emptypb.Empty, error)

func (UnimplementedCoordinatorControlServiceServer) NewWorker 

func (UnimplementedCoordinatorControlServiceServer) NewWorker(context.Context, *NewWorkerRequest) (*emptypb.Empty, error)

func (UnimplementedCoordinatorControlServiceServer) PatchTarget 

func (UnimplementedCoordinatorControlServiceServer) PatchTarget(context.Context, *PatchTargetRequest) (*emptypb.Empty, error)

func (UnimplementedCoordinatorControlServiceServer) PatchWorker 

func (UnimplementedCoordinatorControlServiceServer) PatchWorker(context.Context, *PatchWorkerRequest) (*emptypb.Empty, error)

type UnsafeCoordinatorControlServiceServer 

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

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

type WorkersResponse 

type WorkersResponse struct {
	Workers []*shared.Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkersResponse) Descriptor deprecated 

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

Deprecated: Use WorkersResponse.ProtoReflect.Descriptor instead.

func (*WorkersResponse) GetWorkers 

func (x *WorkersResponse) GetWorkers() []*shared.Worker

func (*WorkersResponse) ProtoMessage 

func (*WorkersResponse) ProtoMessage()

func (*WorkersResponse) ProtoReflect 

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

func (*WorkersResponse) Reset 

func (x *WorkersResponse) Reset()

func (*WorkersResponse) String 

func (x *WorkersResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.