manager

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Jun 1, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	CommandStatus_name = map[int32]string{
		0: "SUCCESS",
		1: "FAIL",
	}
	CommandStatus_value = map[string]int32{
		"SUCCESS": 0,
		"FAIL":    1,
	}
)

Enum value maps for CommandStatus.

View Source
var (
	ExecuteResponse_State_name = map[int32]string{
		0: "NONE",
		1: "PENDING",
		2: "INPROGRESS",
		3: "SUCCESS",
		4: "FAILURE",
		5: "TIMEOUT",
	}
	ExecuteResponse_State_value = map[string]int32{
		"NONE":       0,
		"PENDING":    1,
		"INPROGRESS": 2,
		"SUCCESS":    3,
		"FAILURE":    4,
		"TIMEOUT":    5,
	}
)

Enum value maps for ExecuteResponse_State.

View Source
var File_proto_dsrv_api_node_manager_v1_manager_proto protoreflect.FileDescriptor
View Source
var NodeManager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pilot.manager.NodeManager",
	HandlerType: (*NodeManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _NodeManager_Init_Handler,
		},
		{
			MethodName: "Verify",
			Handler:    _NodeManager_Verify_Handler,
		},
		{
			MethodName: "End",
			Handler:    _NodeManager_End_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _NodeManager_Execute_Handler,
		},
		{
			MethodName: "UpdateConfig",
			Handler:    _NodeManager_UpdateConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/dsrv/api/node_manager/v1/manager.proto",
}

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

Functions

func RegisterNodeManagerServer

func RegisterNodeManagerServer(s grpc.ServiceRegistrar, srv NodeManagerServer)

Types

type CommandStatus

type CommandStatus int32
const (
	CommandStatus_SUCCESS CommandStatus = 0
	CommandStatus_FAIL    CommandStatus = 1
)

func (CommandStatus) Descriptor

func (CommandStatus) Enum

func (x CommandStatus) Enum() *CommandStatus

func (CommandStatus) EnumDescriptor deprecated

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

Deprecated: Use CommandStatus.Descriptor instead.

func (CommandStatus) Number

func (CommandStatus) String

func (x CommandStatus) String() string

func (CommandStatus) Type

type EndRequest

type EndRequest struct {
	Metadata *structpb.Struct `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*EndRequest) Descriptor deprecated

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

Deprecated: Use EndRequest.ProtoReflect.Descriptor instead.

func (*EndRequest) GetMetadata

func (x *EndRequest) GetMetadata() *structpb.Struct

func (*EndRequest) ProtoMessage

func (*EndRequest) ProtoMessage()

func (*EndRequest) ProtoReflect

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

func (*EndRequest) Reset

func (x *EndRequest) Reset()

func (*EndRequest) String

func (x *EndRequest) String() string

type EndResponse

type EndResponse struct {
	Result CommandStatus `protobuf:"varint,1,opt,name=result,proto3,enum=pilot.manager.CommandStatus" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*EndResponse) Descriptor deprecated

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

Deprecated: Use EndResponse.ProtoReflect.Descriptor instead.

func (*EndResponse) GetResult

func (x *EndResponse) GetResult() CommandStatus

func (*EndResponse) ProtoMessage

func (*EndResponse) ProtoMessage()

func (*EndResponse) ProtoReflect

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

func (*EndResponse) Reset

func (x *EndResponse) Reset()

func (*EndResponse) String

func (x *EndResponse) String() string

type ExecuteRequest

type ExecuteRequest struct {

	// is_required: true
	TargetInfo *structpb.Struct `protobuf:"bytes,1,opt,name=target_info,json=targetInfo,proto3" json:"target_info,omitempty"`
	// is_required: true
	Command *structpb.Struct `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetCommand

func (x *ExecuteRequest) GetCommand() *structpb.Struct

func (*ExecuteRequest) GetTargetInfo

func (x *ExecuteRequest) GetTargetInfo() *structpb.Struct

func (*ExecuteRequest) ProtoMessage

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect

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

func (*ExecuteRequest) Reset

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String

func (x *ExecuteRequest) String() string

type ExecuteResponse

type ExecuteResponse struct {
	State    ExecuteResponse_State `protobuf:"varint,1,opt,name=state,proto3,enum=pilot.manager.ExecuteResponse_State" json:"state,omitempty"`
	Message  string                `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Protocol string                `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Options  *structpb.Struct      `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetMessage

func (x *ExecuteResponse) GetMessage() string

func (*ExecuteResponse) GetOptions

func (x *ExecuteResponse) GetOptions() *structpb.Struct

func (*ExecuteResponse) GetProtocol

func (x *ExecuteResponse) GetProtocol() string

func (*ExecuteResponse) GetState

func (x *ExecuteResponse) GetState() ExecuteResponse_State

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect

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

func (*ExecuteResponse) Reset

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (x *ExecuteResponse) String() string

type ExecuteResponse_State

type ExecuteResponse_State int32
const (
	ExecuteResponse_NONE       ExecuteResponse_State = 0
	ExecuteResponse_PENDING    ExecuteResponse_State = 1
	ExecuteResponse_INPROGRESS ExecuteResponse_State = 2
	ExecuteResponse_SUCCESS    ExecuteResponse_State = 3
	ExecuteResponse_FAILURE    ExecuteResponse_State = 4
	ExecuteResponse_TIMEOUT    ExecuteResponse_State = 5
)

func (ExecuteResponse_State) Descriptor

func (ExecuteResponse_State) Enum

func (ExecuteResponse_State) EnumDescriptor deprecated

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

Deprecated: Use ExecuteResponse_State.Descriptor instead.

func (ExecuteResponse_State) Number

func (ExecuteResponse_State) String

func (x ExecuteResponse_State) String() string

func (ExecuteResponse_State) Type

type InitRequest

type InitRequest struct {

	// is_required: true
	Options *structpb.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetOptions

func (x *InitRequest) GetOptions() *structpb.Struct

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

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

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

type InitResponse

type InitResponse struct {
	Result   CommandStatus    `protobuf:"varint,1,opt,name=result,proto3,enum=pilot.manager.CommandStatus" json:"result,omitempty"`
	Metadata *structpb.Struct `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*InitResponse) Descriptor deprecated

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) GetMetadata

func (x *InitResponse) GetMetadata() *structpb.Struct

func (*InitResponse) GetResult

func (x *InitResponse) GetResult() CommandStatus

func (*InitResponse) ProtoMessage

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect

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

func (*InitResponse) Reset

func (x *InitResponse) Reset()

func (*InitResponse) String

func (x *InitResponse) String() string

type NodeManagerClient

type NodeManagerClient interface {
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
	Verify(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyInfo, error)
	End(ctx context.Context, in *EndRequest, opts ...grpc.CallOption) (*EndResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	UpdateConfig(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
}

NodeManagerClient is the client API for NodeManager 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.

type NodeManagerServer

type NodeManagerServer interface {
	Init(context.Context, *InitRequest) (*InitResponse, error)
	Verify(context.Context, *VerifyRequest) (*VerifyInfo, error)
	End(context.Context, *EndRequest) (*EndResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	UpdateConfig(context.Context, *UpdateRequest) (*UpdateResponse, error)
	// contains filtered or unexported methods
}

NodeManagerServer is the server API for NodeManager service. All implementations must embed UnimplementedNodeManagerServer for forward compatibility

type UnimplementedNodeManagerServer

type UnimplementedNodeManagerServer struct {
}

UnimplementedNodeManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeManagerServer) End

func (UnimplementedNodeManagerServer) Execute

func (UnimplementedNodeManagerServer) Init

func (UnimplementedNodeManagerServer) UpdateConfig

func (UnimplementedNodeManagerServer) Verify

type UnsafeNodeManagerServer

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

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

type UpdateRequest

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

func (*UpdateRequest) Descriptor deprecated

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) ProtoMessage

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect

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

func (*UpdateRequest) Reset

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String

func (x *UpdateRequest) String() string

type UpdateResponse

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

func (*UpdateResponse) Descriptor deprecated

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) ProtoMessage

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect

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

func (*UpdateResponse) Reset

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String

func (x *UpdateResponse) String() string

type VerifyInfo

type VerifyInfo struct {
	Result CommandStatus `protobuf:"varint,1,opt,name=result,proto3,enum=pilot.manager.CommandStatus" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyInfo) Descriptor deprecated

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

Deprecated: Use VerifyInfo.ProtoReflect.Descriptor instead.

func (*VerifyInfo) GetResult

func (x *VerifyInfo) GetResult() CommandStatus

func (*VerifyInfo) ProtoMessage

func (*VerifyInfo) ProtoMessage()

func (*VerifyInfo) ProtoReflect

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

func (*VerifyInfo) Reset

func (x *VerifyInfo) Reset()

func (*VerifyInfo) String

func (x *VerifyInfo) String() string

type VerifyRequest

type VerifyRequest struct {

	// is_required: true
	Options *structpb.Struct `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyRequest) Descriptor deprecated

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

Deprecated: Use VerifyRequest.ProtoReflect.Descriptor instead.

func (*VerifyRequest) GetOptions

func (x *VerifyRequest) GetOptions() *structpb.Struct

func (*VerifyRequest) ProtoMessage

func (*VerifyRequest) ProtoMessage()

func (*VerifyRequest) ProtoReflect

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

func (*VerifyRequest) Reset

func (x *VerifyRequest) Reset()

func (*VerifyRequest) String

func (x *VerifyRequest) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL