command

package
v1.9.5 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2024 License: MPL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HandlerService_AddInbound_FullMethodName     = "/xray.app.proxyman.command.HandlerService/AddInbound"
	HandlerService_RemoveInbound_FullMethodName  = "/xray.app.proxyman.command.HandlerService/RemoveInbound"
	HandlerService_AlterInbound_FullMethodName   = "/xray.app.proxyman.command.HandlerService/AlterInbound"
	HandlerService_AddOutbound_FullMethodName    = "/xray.app.proxyman.command.HandlerService/AddOutbound"
	HandlerService_RemoveOutbound_FullMethodName = "/xray.app.proxyman.command.HandlerService/RemoveOutbound"
	HandlerService_AlterOutbound_FullMethodName  = "/xray.app.proxyman.command.HandlerService/AlterOutbound"
)

Variables

View Source 
var File_app_proxyman_command_command_proto protoreflect.FileDescriptor
View Source 
var HandlerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "xray.app.proxyman.command.HandlerService",
	HandlerType: (*HandlerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddInbound",
			Handler:    _HandlerService_AddInbound_Handler,
		},
		{
			MethodName: "RemoveInbound",
			Handler:    _HandlerService_RemoveInbound_Handler,
		},
		{
			MethodName: "AlterInbound",
			Handler:    _HandlerService_AlterInbound_Handler,
		},
		{
			MethodName: "AddOutbound",
			Handler:    _HandlerService_AddOutbound_Handler,
		},
		{
			MethodName: "RemoveOutbound",
			Handler:    _HandlerService_RemoveOutbound_Handler,
		},
		{
			MethodName: "AlterOutbound",
			Handler:    _HandlerService_AlterOutbound_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "app/proxyman/command/command.proto",
}

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

Functions

func RegisterHandlerServiceServer 

func RegisterHandlerServiceServer(s grpc.ServiceRegistrar, srv HandlerServiceServer)

Types

type AddInboundRequest 

type AddInboundRequest struct {
	Inbound *core.InboundHandlerConfig `protobuf:"bytes,1,opt,name=inbound,proto3" json:"inbound,omitempty"`
	// contains filtered or unexported fields
}

func (*AddInboundRequest) Descriptor deprecated 

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

Deprecated: Use AddInboundRequest.ProtoReflect.Descriptor instead.

func (*AddInboundRequest) GetInbound 

func (x *AddInboundRequest) GetInbound() *core.InboundHandlerConfig

func (*AddInboundRequest) ProtoMessage 

func (*AddInboundRequest) ProtoMessage()

func (*AddInboundRequest) ProtoReflect 

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

func (*AddInboundRequest) Reset 

func (x *AddInboundRequest) Reset()

func (*AddInboundRequest) String 

func (x *AddInboundRequest) String() string

type AddInboundResponse 

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

func (*AddInboundResponse) Descriptor deprecated 

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

Deprecated: Use AddInboundResponse.ProtoReflect.Descriptor instead.

func (*AddInboundResponse) ProtoMessage 

func (*AddInboundResponse) ProtoMessage()

func (*AddInboundResponse) ProtoReflect 

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

func (*AddInboundResponse) Reset 

func (x *AddInboundResponse) Reset()

func (*AddInboundResponse) String 

func (x *AddInboundResponse) String() string

type AddOutboundRequest 

type AddOutboundRequest struct {
	Outbound *core.OutboundHandlerConfig `protobuf:"bytes,1,opt,name=outbound,proto3" json:"outbound,omitempty"`
	// contains filtered or unexported fields
}

func (*AddOutboundRequest) Descriptor deprecated 

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

Deprecated: Use AddOutboundRequest.ProtoReflect.Descriptor instead.

func (*AddOutboundRequest) GetOutbound 

func (x *AddOutboundRequest) GetOutbound() *core.OutboundHandlerConfig

func (*AddOutboundRequest) ProtoMessage 

func (*AddOutboundRequest) ProtoMessage()

func (*AddOutboundRequest) ProtoReflect 

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

func (*AddOutboundRequest) Reset 

func (x *AddOutboundRequest) Reset()

func (*AddOutboundRequest) String 

func (x *AddOutboundRequest) String() string

type AddOutboundResponse 

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

func (*AddOutboundResponse) Descriptor deprecated 

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

Deprecated: Use AddOutboundResponse.ProtoReflect.Descriptor instead.

func (*AddOutboundResponse) ProtoMessage 

func (*AddOutboundResponse) ProtoMessage()

func (*AddOutboundResponse) ProtoReflect 

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

func (*AddOutboundResponse) Reset 

func (x *AddOutboundResponse) Reset()

func (*AddOutboundResponse) String 

func (x *AddOutboundResponse) String() string

type AddUserOperation 

type AddUserOperation struct {
	User *protocol.User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*AddUserOperation) ApplyInbound 

func (op *AddUserOperation) ApplyInbound(ctx context.Context, handler inbound.Handler) error

ApplyInbound implements InboundOperation.

func (*AddUserOperation) Descriptor deprecated 

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

Deprecated: Use AddUserOperation.ProtoReflect.Descriptor instead.

func (*AddUserOperation) GetUser 

func (x *AddUserOperation) GetUser() *protocol.User

func (*AddUserOperation) ProtoMessage 

func (*AddUserOperation) ProtoMessage()

func (*AddUserOperation) ProtoReflect 

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

func (*AddUserOperation) Reset 

func (x *AddUserOperation) Reset()

func (*AddUserOperation) String 

func (x *AddUserOperation) String() string

type AlterInboundRequest 

type AlterInboundRequest struct {
	Tag       string               `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Operation *serial.TypedMessage `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterInboundRequest) Descriptor deprecated 

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

Deprecated: Use AlterInboundRequest.ProtoReflect.Descriptor instead.

func (*AlterInboundRequest) GetOperation 

func (x *AlterInboundRequest) GetOperation() *serial.TypedMessage

func (*AlterInboundRequest) GetTag 

func (x *AlterInboundRequest) GetTag() string

func (*AlterInboundRequest) ProtoMessage 

func (*AlterInboundRequest) ProtoMessage()

func (*AlterInboundRequest) ProtoReflect 

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

func (*AlterInboundRequest) Reset 

func (x *AlterInboundRequest) Reset()

func (*AlterInboundRequest) String 

func (x *AlterInboundRequest) String() string

type AlterInboundResponse 

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

func (*AlterInboundResponse) Descriptor deprecated 

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

Deprecated: Use AlterInboundResponse.ProtoReflect.Descriptor instead.

func (*AlterInboundResponse) ProtoMessage 

func (*AlterInboundResponse) ProtoMessage()

func (*AlterInboundResponse) ProtoReflect 

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

func (*AlterInboundResponse) Reset 

func (x *AlterInboundResponse) Reset()

func (*AlterInboundResponse) String 

func (x *AlterInboundResponse) String() string

type AlterOutboundRequest 

type AlterOutboundRequest struct {
	Tag       string               `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	Operation *serial.TypedMessage `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*AlterOutboundRequest) Descriptor deprecated 

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

Deprecated: Use AlterOutboundRequest.ProtoReflect.Descriptor instead.

func (*AlterOutboundRequest) GetOperation 

func (x *AlterOutboundRequest) GetOperation() *serial.TypedMessage

func (*AlterOutboundRequest) GetTag 

func (x *AlterOutboundRequest) GetTag() string

func (*AlterOutboundRequest) ProtoMessage 

func (*AlterOutboundRequest) ProtoMessage()

func (*AlterOutboundRequest) ProtoReflect 

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

func (*AlterOutboundRequest) Reset 

func (x *AlterOutboundRequest) Reset()

func (*AlterOutboundRequest) String 

func (x *AlterOutboundRequest) String() string

type AlterOutboundResponse 

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

func (*AlterOutboundResponse) Descriptor deprecated 

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

Deprecated: Use AlterOutboundResponse.ProtoReflect.Descriptor instead.

func (*AlterOutboundResponse) ProtoMessage 

func (*AlterOutboundResponse) ProtoMessage()

func (*AlterOutboundResponse) ProtoReflect 

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

func (*AlterOutboundResponse) Reset 

func (x *AlterOutboundResponse) Reset()

func (*AlterOutboundResponse) String 

func (x *AlterOutboundResponse) String() string

type Config 

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

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type HandlerServiceClient 

type HandlerServiceClient interface {
	AddInbound(ctx context.Context, in *AddInboundRequest, opts ...grpc.CallOption) (*AddInboundResponse, error)
	RemoveInbound(ctx context.Context, in *RemoveInboundRequest, opts ...grpc.CallOption) (*RemoveInboundResponse, error)
	AlterInbound(ctx context.Context, in *AlterInboundRequest, opts ...grpc.CallOption) (*AlterInboundResponse, error)
	AddOutbound(ctx context.Context, in *AddOutboundRequest, opts ...grpc.CallOption) (*AddOutboundResponse, error)
	RemoveOutbound(ctx context.Context, in *RemoveOutboundRequest, opts ...grpc.CallOption) (*RemoveOutboundResponse, error)
	AlterOutbound(ctx context.Context, in *AlterOutboundRequest, opts ...grpc.CallOption) (*AlterOutboundResponse, error)
}

HandlerServiceClient is the client API for HandlerService 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 NewHandlerServiceClient 

func NewHandlerServiceClient(cc grpc.ClientConnInterface) HandlerServiceClient

type HandlerServiceServer 

type HandlerServiceServer interface {
	AddInbound(context.Context, *AddInboundRequest) (*AddInboundResponse, error)
	RemoveInbound(context.Context, *RemoveInboundRequest) (*RemoveInboundResponse, error)
	AlterInbound(context.Context, *AlterInboundRequest) (*AlterInboundResponse, error)
	AddOutbound(context.Context, *AddOutboundRequest) (*AddOutboundResponse, error)
	RemoveOutbound(context.Context, *RemoveOutboundRequest) (*RemoveOutboundResponse, error)
	AlterOutbound(context.Context, *AlterOutboundRequest) (*AlterOutboundResponse, error)
	// contains filtered or unexported methods
}

HandlerServiceServer is the server API for HandlerService service. All implementations must embed UnimplementedHandlerServiceServer for forward compatibility.

type InboundOperation 

type InboundOperation interface {
	// ApplyInbound applies this operation to the given inbound handler.
	ApplyInbound(context.Context, inbound.Handler) error
}

InboundOperation is the interface for operations that applies to inbound handlers.

type OutboundOperation 

type OutboundOperation interface {
	// ApplyOutbound applies this operation to the given outbound handler.
	ApplyOutbound(context.Context, outbound.Handler) error
}

OutboundOperation is the interface for operations that applies to outbound handlers.

type RemoveInboundRequest 

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

func (*RemoveInboundRequest) Descriptor deprecated 

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

Deprecated: Use RemoveInboundRequest.ProtoReflect.Descriptor instead.

func (*RemoveInboundRequest) GetTag 

func (x *RemoveInboundRequest) GetTag() string

func (*RemoveInboundRequest) ProtoMessage 

func (*RemoveInboundRequest) ProtoMessage()

func (*RemoveInboundRequest) ProtoReflect 

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

func (*RemoveInboundRequest) Reset 

func (x *RemoveInboundRequest) Reset()

func (*RemoveInboundRequest) String 

func (x *RemoveInboundRequest) String() string

type RemoveInboundResponse 

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

func (*RemoveInboundResponse) Descriptor deprecated 

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

Deprecated: Use RemoveInboundResponse.ProtoReflect.Descriptor instead.

func (*RemoveInboundResponse) ProtoMessage 

func (*RemoveInboundResponse) ProtoMessage()

func (*RemoveInboundResponse) ProtoReflect 

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

func (*RemoveInboundResponse) Reset 

func (x *RemoveInboundResponse) Reset()

func (*RemoveInboundResponse) String 

func (x *RemoveInboundResponse) String() string

type RemoveOutboundRequest 

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

func (*RemoveOutboundRequest) Descriptor deprecated 

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

Deprecated: Use RemoveOutboundRequest.ProtoReflect.Descriptor instead.

func (*RemoveOutboundRequest) GetTag 

func (x *RemoveOutboundRequest) GetTag() string

func (*RemoveOutboundRequest) ProtoMessage 

func (*RemoveOutboundRequest) ProtoMessage()

func (*RemoveOutboundRequest) ProtoReflect 

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

func (*RemoveOutboundRequest) Reset 

func (x *RemoveOutboundRequest) Reset()

func (*RemoveOutboundRequest) String 

func (x *RemoveOutboundRequest) String() string

type RemoveOutboundResponse 

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

func (*RemoveOutboundResponse) Descriptor deprecated 

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

Deprecated: Use RemoveOutboundResponse.ProtoReflect.Descriptor instead.

func (*RemoveOutboundResponse) ProtoMessage 

func (*RemoveOutboundResponse) ProtoMessage()

func (*RemoveOutboundResponse) ProtoReflect 

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

func (*RemoveOutboundResponse) Reset 

func (x *RemoveOutboundResponse) Reset()

func (*RemoveOutboundResponse) String 

func (x *RemoveOutboundResponse) String() string

type RemoveUserOperation 

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

func (*RemoveUserOperation) ApplyInbound 

func (op *RemoveUserOperation) ApplyInbound(ctx context.Context, handler inbound.Handler) error

ApplyInbound implements InboundOperation.

func (*RemoveUserOperation) Descriptor deprecated 

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

Deprecated: Use RemoveUserOperation.ProtoReflect.Descriptor instead.

func (*RemoveUserOperation) GetEmail 

func (x *RemoveUserOperation) GetEmail() string

func (*RemoveUserOperation) ProtoMessage 

func (*RemoveUserOperation) ProtoMessage()

func (*RemoveUserOperation) ProtoReflect 

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

func (*RemoveUserOperation) Reset 

func (x *RemoveUserOperation) Reset()

func (*RemoveUserOperation) String 

func (x *RemoveUserOperation) String() string

type UnimplementedHandlerServiceServer 

type UnimplementedHandlerServiceServer struct{}

UnimplementedHandlerServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedHandlerServiceServer) AddInbound 

func (UnimplementedHandlerServiceServer) AddInbound(context.Context, *AddInboundRequest) (*AddInboundResponse, error)

func (UnimplementedHandlerServiceServer) AddOutbound 

func (UnimplementedHandlerServiceServer) AddOutbound(context.Context, *AddOutboundRequest) (*AddOutboundResponse, error)

func (UnimplementedHandlerServiceServer) AlterInbound 

func (UnimplementedHandlerServiceServer) AlterInbound(context.Context, *AlterInboundRequest) (*AlterInboundResponse, error)

func (UnimplementedHandlerServiceServer) AlterOutbound 

func (UnimplementedHandlerServiceServer) AlterOutbound(context.Context, *AlterOutboundRequest) (*AlterOutboundResponse, error)

func (UnimplementedHandlerServiceServer) RemoveInbound 

func (UnimplementedHandlerServiceServer) RemoveInbound(context.Context, *RemoveInboundRequest) (*RemoveInboundResponse, error)

func (UnimplementedHandlerServiceServer) RemoveOutbound 

func (UnimplementedHandlerServiceServer) RemoveOutbound(context.Context, *RemoveOutboundRequest) (*RemoveOutboundResponse, error)

type UnsafeHandlerServiceServer 

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

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