v1

package
v0.0.0-...-f5c5fc0 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2022 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: "IN_PROGRESS",
		3: "SUCCESS",
		4: "FAILURE",
		5: "TIMEOUT",
	}
	ExecuteResponse_State_value = map[string]int32{
		"NONE":        0,
		"PENDING":     1,
		"IN_PROGRESS": 2,
		"SUCCESS":     3,
		"FAILURE":     4,
		"TIMEOUT":     5,
	}
)

Enum value maps for ExecuteResponse_State.

View Source 
var File_proto_vatz_manager_v1_manager_proto protoreflect.FileDescriptor
View Source 
var Manager_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vatz.manager.Manager",
	HandlerType: (*ManagerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _Manager_Init_Handler,
		},
		{
			MethodName: "Verify",
			Handler:    _Manager_Verify_Handler,
		},
		{
			MethodName: "End",
			Handler:    _Manager_End_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _Manager_Execute_Handler,
		},
		{
			MethodName: "UpdateConfig",
			Handler:    _Manager_UpdateConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/vatz/manager/v1/manager.proto",
}

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

Functions

func RegisterManagerServer 

func RegisterManagerServer(s grpc.ServiceRegistrar, srv ManagerServer)

Types

type CommandStatus 

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

func (CommandStatus) Descriptor 

func (CommandStatus) Descriptor() protoreflect.EnumDescriptor

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 (x CommandStatus) Number() protoreflect.EnumNumber

func (CommandStatus) String 

func (x CommandStatus) String() string

func (CommandStatus) Type 

func (CommandStatus) Type() protoreflect.EnumType

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=vatz.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=vatz.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_IN_PROGRESS 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) Descriptor() protoreflect.EnumDescriptor

func (ExecuteResponse_State) Enum 

func (x ExecuteResponse_State) Enum() *ExecuteResponse_State

func (ExecuteResponse_State) EnumDescriptor deprecated 

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

Deprecated: Use ExecuteResponse_State.Descriptor instead.

func (ExecuteResponse_State) Number 

func (x ExecuteResponse_State) Number() protoreflect.EnumNumber

func (ExecuteResponse_State) String 

func (x ExecuteResponse_State) String() string

func (ExecuteResponse_State) Type 

func (ExecuteResponse_State) Type() protoreflect.EnumType

type InitRequest 

type InitRequest struct {
	Name    string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address string           `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port    int32            `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	Version float32          `protobuf:"fixed32,4,opt,name=version,proto3" json:"version,omitempty"` // version >< revision 때문에 정확한 타입지정이 필요
	Option  *structpb.Struct `protobuf:"bytes,5,opt,name=option,proto3" json:"option,omitempty"`     // mapType 변환
	// contains filtered or unexported fields
}

Metadata 레퍼런스로 항상 넣어서 사용하지 않더라도 넣어주는 값 option 필수값은 아님 항상 변경이 될 수 있는 값

func (*InitRequest) Descriptor deprecated 

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetAddress 

func (x *InitRequest) GetAddress() string

func (*InitRequest) GetName 

func (x *InitRequest) GetName() string

func (*InitRequest) GetOption 

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

func (*InitRequest) GetPort 

func (x *InitRequest) GetPort() int32

func (*InitRequest) GetVersion 

func (x *InitRequest) GetVersion() float32

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=vatz.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 ManagerClient 

type ManagerClient 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)
}

ManagerClient is the client API for Manager 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 NewManagerClient 

func NewManagerClient(cc grpc.ClientConnInterface) ManagerClient

type ManagerServer 

type ManagerServer 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
}

ManagerServer is the server API for Manager service. All implementations must embed UnimplementedManagerServer for forward compatibility

type UnimplementedManagerServer 

type UnimplementedManagerServer struct {
}

UnimplementedManagerServer must be embedded to have forward compatible implementations.

func (UnimplementedManagerServer) End 

func (UnimplementedManagerServer) End(context.Context, *EndRequest) (*EndResponse, error)

func (UnimplementedManagerServer) Execute 

func (UnimplementedManagerServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

func (UnimplementedManagerServer) Init 

func (UnimplementedManagerServer) Init(context.Context, *InitRequest) (*InitResponse, error)

func (UnimplementedManagerServer) UpdateConfig 

func (UnimplementedManagerServer) UpdateConfig(context.Context, *UpdateRequest) (*UpdateResponse, error)

func (UnimplementedManagerServer) Verify 

func (UnimplementedManagerServer) Verify(context.Context, *VerifyRequest) (*VerifyInfo, error)

type UnsafeManagerServer 

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

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

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.