command

package
v0.0.0-...-6c925ee Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCommand        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommand          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCommand = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CommandType_name = map[int32]string{
	0:  "EMPTY",
	1:  "ListDir",
	2:  "Push",
	3:  "Pull",
	4:  "Screenshot",
	5:  "Forward",
	6:  "Reverse",
	7:  "ForwardReceive",
	8:  "ReverseReceive",
	9:  "ListTunnel",
	10: "CloseTunnel",
}
View Source 
var CommandType_value = map[string]int32{
	"EMPTY":          0,
	"ListDir":        1,
	"Push":           2,
	"Pull":           3,
	"Screenshot":     4,
	"Forward":        5,
	"Reverse":        6,
	"ForwardReceive": 7,
	"ReverseReceive": 8,
	"ListTunnel":     9,
	"CloseTunnel":    10,
}
View Source 
var TunnelDirection_name = map[int32]string{
	0: "DIRECTION_KNOWN",
	1: "DIRECTION_FORWARD",
	2: "DIRECTION_REVERSE",
}
View Source 
var TunnelDirection_value = map[string]int32{
	"DIRECTION_KNOWN":   0,
	"DIRECTION_FORWARD": 1,
	"DIRECTION_REVERSE": 2,
}

Functions

This section is empty.

Types

type Args 

type Args map[string]Command_Arg

type Command 

type Command struct {
	Type CommandType            `protobuf:"varint,1,opt,name=type,proto3,enum=command.CommandType" json:"type" yaml:"-"`
	Args map[string]Command_Arg `` /* 148-byte string literal not displayed */
}

func EmptyCommand 

func EmptyCommand() *Command

func (*Command) Descriptor 

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

func (*Command) GetArgs 

func (m *Command) GetArgs() map[string]Command_Arg

func (*Command) GetType 

func (m *Command) GetType() CommandType

func (*Command) Marshal 

func (m *Command) Marshal() (dAtA []byte, err error)

func (*Command) MarshalTo 

func (m *Command) MarshalTo(dAtA []byte) (int, error)

func (*Command) MarshalToSizedBuffer 

func (m *Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoSize 

func (m *Command) ProtoSize() (n int)

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

func (m *Command) Unmarshal(dAtA []byte) error

func (*Command) XXX_DiscardUnknown 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal 

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge 

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_Size 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal 

func (m *Command) XXX_Unmarshal(b []byte) error

type CommandProvider 

type CommandProvider interface {
	Invoke(ctx context.Context, cmd *Command, opt *RemoteOpt) (proto.Message, error)
}

type CommandType 

type CommandType int32
const (
	// EMPTY is the type of command sent during connection establishment
	Empty          CommandType = 0
	Listdir        CommandType = 1
	Push           CommandType = 2
	Pull           CommandType = 3
	Screenshot     CommandType = 4
	Forward        CommandType = 5
	Reverse        CommandType = 6
	Forwardreceive CommandType = 7
	Reversereceive CommandType = 8
	Listtunnel     CommandType = 9
	Closetunnel    CommandType = 10
)

func (CommandType) EnumDescriptor 

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

func (CommandType) String 

func (x CommandType) String() string

type Command_Arg 

type Command_Arg struct {
	// Types that are valid to be assigned to Value:
	//
	//	*Command_Arg_StrValue
	//	*Command_Arg_IntValue
	//	*Command_Arg_BoolValue
	Value isCommand_Arg_Value `protobuf_oneof:"value"`
}

func BoolArg 

func BoolArg(val bool) Command_Arg

func IntArg 

func IntArg(val int64) Command_Arg

func StrArg 

func StrArg(val string) Command_Arg

func (*Command_Arg) Descriptor 

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

func (*Command_Arg) GetBoolValue 

func (m *Command_Arg) GetBoolValue() bool

func (*Command_Arg) GetIntValue 

func (m *Command_Arg) GetIntValue() int64

func (*Command_Arg) GetStrValue 

func (m *Command_Arg) GetStrValue() string

func (*Command_Arg) GetValue 

func (m *Command_Arg) GetValue() isCommand_Arg_Value

func (*Command_Arg) Marshal 

func (m *Command_Arg) Marshal() (dAtA []byte, err error)

func (*Command_Arg) MarshalTo 

func (m *Command_Arg) MarshalTo(dAtA []byte) (int, error)

func (*Command_Arg) MarshalToSizedBuffer 

func (m *Command_Arg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Command_Arg) ProtoMessage 

func (*Command_Arg) ProtoMessage()

func (*Command_Arg) ProtoSize 

func (m *Command_Arg) ProtoSize() (n int)

func (*Command_Arg) Reset 

func (m *Command_Arg) Reset()

func (*Command_Arg) String 

func (m *Command_Arg) String() string

func (*Command_Arg) Unmarshal 

func (m *Command_Arg) Unmarshal(dAtA []byte) error

func (*Command_Arg) XXX_DiscardUnknown 

func (m *Command_Arg) XXX_DiscardUnknown()

func (*Command_Arg) XXX_Marshal 

func (m *Command_Arg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command_Arg) XXX_Merge 

func (m *Command_Arg) XXX_Merge(src proto.Message)

func (*Command_Arg) XXX_OneofWrappers 

func (*Command_Arg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Command_Arg) XXX_Size 

func (m *Command_Arg) XXX_Size() int

func (*Command_Arg) XXX_Unmarshal 

func (m *Command_Arg) XXX_Unmarshal(b []byte) error

type Command_Arg_BoolValue 

type Command_Arg_BoolValue struct {
	BoolValue bool `protobuf:"varint,3,opt,name=bool_value,json=boolValue,proto3,oneof" json:"boolValue" yaml:"-"`
}

func (*Command_Arg_BoolValue) MarshalTo 

func (m *Command_Arg_BoolValue) MarshalTo(dAtA []byte) (int, error)

func (*Command_Arg_BoolValue) MarshalToSizedBuffer 

func (m *Command_Arg_BoolValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Command_Arg_BoolValue) ProtoSize 

func (m *Command_Arg_BoolValue) ProtoSize() (n int)

type Command_Arg_IntValue 

type Command_Arg_IntValue struct {
	IntValue int64 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof" json:"intValue" yaml:"-"`
}

func (*Command_Arg_IntValue) MarshalTo 

func (m *Command_Arg_IntValue) MarshalTo(dAtA []byte) (int, error)

func (*Command_Arg_IntValue) MarshalToSizedBuffer 

func (m *Command_Arg_IntValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Command_Arg_IntValue) ProtoSize 

func (m *Command_Arg_IntValue) ProtoSize() (n int)

type Command_Arg_StrValue 

type Command_Arg_StrValue struct {
	StrValue string `protobuf:"bytes,1,opt,name=str_value,json=strValue,proto3,oneof" json:"strValue" yaml:"-"`
}

func (*Command_Arg_StrValue) MarshalTo 

func (m *Command_Arg_StrValue) MarshalTo(dAtA []byte) (int, error)

func (*Command_Arg_StrValue) MarshalToSizedBuffer 

func (m *Command_Arg_StrValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Command_Arg_StrValue) ProtoSize 

func (m *Command_Arg_StrValue) ProtoSize() (n int)

type ListTunnelResp 

type ListTunnelResp struct {
	Tunnels []*Tunnel `protobuf:"bytes,1,rep,name=tunnels,proto3" json:"tunnels" yaml:"-"`
}

func (*ListTunnelResp) Descriptor 

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

func (*ListTunnelResp) GetTunnels 

func (m *ListTunnelResp) GetTunnels() []*Tunnel

func (*ListTunnelResp) Marshal 

func (m *ListTunnelResp) Marshal() (dAtA []byte, err error)

func (*ListTunnelResp) MarshalTo 

func (m *ListTunnelResp) MarshalTo(dAtA []byte) (int, error)

func (*ListTunnelResp) MarshalToSizedBuffer 

func (m *ListTunnelResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTunnelResp) ProtoMessage 

func (*ListTunnelResp) ProtoMessage()

func (*ListTunnelResp) ProtoSize 

func (m *ListTunnelResp) ProtoSize() (n int)

func (*ListTunnelResp) Reset 

func (m *ListTunnelResp) Reset()

func (*ListTunnelResp) String 

func (m *ListTunnelResp) String() string

func (*ListTunnelResp) Unmarshal 

func (m *ListTunnelResp) Unmarshal(dAtA []byte) error

func (*ListTunnelResp) XXX_DiscardUnknown 

func (m *ListTunnelResp) XXX_DiscardUnknown()

func (*ListTunnelResp) XXX_Marshal 

func (m *ListTunnelResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTunnelResp) XXX_Merge 

func (m *ListTunnelResp) XXX_Merge(src proto.Message)

func (*ListTunnelResp) XXX_Size 

func (m *ListTunnelResp) XXX_Size() int

func (*ListTunnelResp) XXX_Unmarshal 

func (m *ListTunnelResp) XXX_Unmarshal(b []byte) error

type MapResp 

type MapResp struct {
	Data map[string]string `` /* 148-byte string literal not displayed */
}

func (*MapResp) Descriptor 

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

func (*MapResp) GetData 

func (m *MapResp) GetData() map[string]string

func (*MapResp) Marshal 

func (m *MapResp) Marshal() (dAtA []byte, err error)

func (*MapResp) MarshalTo 

func (m *MapResp) MarshalTo(dAtA []byte) (int, error)

func (*MapResp) MarshalToSizedBuffer 

func (m *MapResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MapResp) ProtoMessage 

func (*MapResp) ProtoMessage()

func (*MapResp) ProtoSize 

func (m *MapResp) ProtoSize() (n int)

func (*MapResp) Reset 

func (m *MapResp) Reset()

func (*MapResp) String 

func (m *MapResp) String() string

func (*MapResp) Unmarshal 

func (m *MapResp) Unmarshal(dAtA []byte) error

func (*MapResp) XXX_DiscardUnknown 

func (m *MapResp) XXX_DiscardUnknown()

func (*MapResp) XXX_Marshal 

func (m *MapResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MapResp) XXX_Merge 

func (m *MapResp) XXX_Merge(src proto.Message)

func (*MapResp) XXX_Size 

func (m *MapResp) XXX_Size() int

func (*MapResp) XXX_Unmarshal 

func (m *MapResp) XXX_Unmarshal(b []byte) error

type RemoteOpt 

type RemoteOpt struct {
	Conn   connection.StreamConnection
	Stream connection.Stream
}

type Ret 

type Ret struct {
	Resp   *types.Any `protobuf:"bytes,1,opt,name=resp,proto3" json:"resp" yaml:"-"`
	ErrNo  uint64     `protobuf:"varint,2,opt,name=err_no,json=errNo,proto3" json:"errNo" yaml:"-"`
	ErrMsg string     `protobuf:"bytes,3,opt,name=err_msg,json=errMsg,proto3" json:"errMsg" yaml:"-"`
}

func (*Ret) Descriptor 

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

func (*Ret) GetErrMsg 

func (m *Ret) GetErrMsg() string

func (*Ret) GetErrNo 

func (m *Ret) GetErrNo() uint64

func (*Ret) GetResp 

func (m *Ret) GetResp() *types.Any

func (*Ret) Marshal 

func (m *Ret) Marshal() (dAtA []byte, err error)

func (*Ret) MarshalJSON 

func (m *Ret) MarshalJSON() ([]byte, error)

func (*Ret) MarshalTo 

func (m *Ret) MarshalTo(dAtA []byte) (int, error)

func (*Ret) MarshalToSizedBuffer 

func (m *Ret) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ret) ProtoMessage 

func (*Ret) ProtoMessage()

func (*Ret) ProtoSize 

func (m *Ret) ProtoSize() (n int)

func (*Ret) Reset 

func (m *Ret) Reset()

func (*Ret) String 

func (m *Ret) String() string

func (*Ret) Unmarshal 

func (m *Ret) Unmarshal(dAtA []byte) error

func (*Ret) XXX_DiscardUnknown 

func (m *Ret) XXX_DiscardUnknown()

func (*Ret) XXX_Marshal 

func (m *Ret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ret) XXX_Merge 

func (m *Ret) XXX_Merge(src proto.Message)

func (*Ret) XXX_Size 

func (m *Ret) XXX_Size() int

func (*Ret) XXX_Unmarshal 

func (m *Ret) XXX_Unmarshal(b []byte) error

type Service 

type Service interface {
	// DoOriginCommand used to process a connection has not yet opened a stream
	// it needs the task handler to open a stream itself
	DoOriginCommand(ctx context.Context, cmd *Command, conn connection.StreamConnection) (*Ret, error)
	DoAcceptCommand(ctx context.Context, cmd *Command, stream connection.Stream) (*Ret, error)
	DoLocalCommand(ctx context.Context, cmd *Command) (*Ret, error)
}

type Tunnel 

type Tunnel struct {
	TunnelKey  string          `protobuf:"bytes,1,opt,name=tunnel_key,json=tunnelKey,proto3" json:"tunnelKey" yaml:"-"`
	LocalAddr  string          `protobuf:"bytes,2,opt,name=local_addr,json=localAddr,proto3" json:"local_addr,omitempty" yaml:"-"`
	RemoteAddr string          `protobuf:"bytes,3,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty" yaml:"-"`
	Direction  TunnelDirection `protobuf:"varint,4,opt,name=direction,proto3,enum=command.TunnelDirection" json:"direction" yaml:"-"`
}

func (*Tunnel) Descriptor 

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

func (*Tunnel) GetDirection 

func (m *Tunnel) GetDirection() TunnelDirection

func (*Tunnel) GetLocalAddr 

func (m *Tunnel) GetLocalAddr() string

func (*Tunnel) GetRemoteAddr 

func (m *Tunnel) GetRemoteAddr() string

func (*Tunnel) GetTunnelKey 

func (m *Tunnel) GetTunnelKey() string

func (*Tunnel) Marshal 

func (m *Tunnel) Marshal() (dAtA []byte, err error)

func (*Tunnel) MarshalTo 

func (m *Tunnel) MarshalTo(dAtA []byte) (int, error)

func (*Tunnel) MarshalToSizedBuffer 

func (m *Tunnel) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tunnel) ProtoMessage 

func (*Tunnel) ProtoMessage()

func (*Tunnel) ProtoSize 

func (m *Tunnel) ProtoSize() (n int)

func (*Tunnel) Reset 

func (m *Tunnel) Reset()

func (*Tunnel) String 

func (m *Tunnel) String() string

func (*Tunnel) Unmarshal 

func (m *Tunnel) Unmarshal(dAtA []byte) error

func (*Tunnel) XXX_DiscardUnknown 

func (m *Tunnel) XXX_DiscardUnknown()

func (*Tunnel) XXX_Marshal 

func (m *Tunnel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tunnel) XXX_Merge 

func (m *Tunnel) XXX_Merge(src proto.Message)

func (*Tunnel) XXX_Size 

func (m *Tunnel) XXX_Size() int

func (*Tunnel) XXX_Unmarshal 

func (m *Tunnel) XXX_Unmarshal(b []byte) error

type TunnelConnect 

type TunnelConnect struct {
	TunnelKey string          `protobuf:"bytes,1,opt,name=tunnel_key,json=tunnelKey,proto3" json:"tunnelKey" yaml:"-"`
	Addr      string          `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr" yaml:"-"`
	Direction TunnelDirection `protobuf:"varint,3,opt,name=direction,proto3,enum=command.TunnelDirection" json:"direction" yaml:"-"`
}

func (*TunnelConnect) Descriptor 

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

func (*TunnelConnect) GetAddr 

func (m *TunnelConnect) GetAddr() string

func (*TunnelConnect) GetDirection 

func (m *TunnelConnect) GetDirection() TunnelDirection

func (*TunnelConnect) GetTunnelKey 

func (m *TunnelConnect) GetTunnelKey() string

func (*TunnelConnect) Marshal 

func (m *TunnelConnect) Marshal() (dAtA []byte, err error)

func (*TunnelConnect) MarshalTo 

func (m *TunnelConnect) MarshalTo(dAtA []byte) (int, error)

func (*TunnelConnect) MarshalToSizedBuffer 

func (m *TunnelConnect) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TunnelConnect) ProtoMessage 

func (*TunnelConnect) ProtoMessage()

func (*TunnelConnect) ProtoSize 

func (m *TunnelConnect) ProtoSize() (n int)

func (*TunnelConnect) Reset 

func (m *TunnelConnect) Reset()

func (*TunnelConnect) String 

func (m *TunnelConnect) String() string

func (*TunnelConnect) ToCommand 

func (tc *TunnelConnect) ToCommand(cmd CommandType) *Command

func (*TunnelConnect) Unmarshal 

func (m *TunnelConnect) Unmarshal(dAtA []byte) error

func (*TunnelConnect) XXX_DiscardUnknown 

func (m *TunnelConnect) XXX_DiscardUnknown()

func (*TunnelConnect) XXX_Marshal 

func (m *TunnelConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TunnelConnect) XXX_Merge 

func (m *TunnelConnect) XXX_Merge(src proto.Message)

func (*TunnelConnect) XXX_Size 

func (m *TunnelConnect) XXX_Size() int

func (*TunnelConnect) XXX_Unmarshal 

func (m *TunnelConnect) XXX_Unmarshal(b []byte) error

type TunnelConnectResp 

type TunnelConnectResp struct {
	TunnelKey string `protobuf:"bytes,1,opt,name=tunnel_key,json=tunnelKey,proto3" json:"tunnelKey" yaml:"-"`
	Success   bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success" yaml:"-"`
	Error     string `protobuf:"bytes,3,opt,name=error,proto3" json:"error" yaml:"-"`
}

func (*TunnelConnectResp) Descriptor 

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

func (*TunnelConnectResp) GetError 

func (m *TunnelConnectResp) GetError() string

func (*TunnelConnectResp) GetSuccess 

func (m *TunnelConnectResp) GetSuccess() bool

func (*TunnelConnectResp) GetTunnelKey 

func (m *TunnelConnectResp) GetTunnelKey() string

func (*TunnelConnectResp) Marshal 

func (m *TunnelConnectResp) Marshal() (dAtA []byte, err error)

func (*TunnelConnectResp) MarshalTo 

func (m *TunnelConnectResp) MarshalTo(dAtA []byte) (int, error)

func (*TunnelConnectResp) MarshalToSizedBuffer 

func (m *TunnelConnectResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TunnelConnectResp) ProtoMessage 

func (*TunnelConnectResp) ProtoMessage()

func (*TunnelConnectResp) ProtoSize 

func (m *TunnelConnectResp) ProtoSize() (n int)

func (*TunnelConnectResp) Reset 

func (m *TunnelConnectResp) Reset()

func (*TunnelConnectResp) String 

func (m *TunnelConnectResp) String() string

func (*TunnelConnectResp) Unmarshal 

func (m *TunnelConnectResp) Unmarshal(dAtA []byte) error

func (*TunnelConnectResp) XXX_DiscardUnknown 

func (m *TunnelConnectResp) XXX_DiscardUnknown()

func (*TunnelConnectResp) XXX_Marshal 

func (m *TunnelConnectResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TunnelConnectResp) XXX_Merge 

func (m *TunnelConnectResp) XXX_Merge(src proto.Message)

func (*TunnelConnectResp) XXX_Size 

func (m *TunnelConnectResp) XXX_Size() int

func (*TunnelConnectResp) XXX_Unmarshal 

func (m *TunnelConnectResp) XXX_Unmarshal(b []byte) error

type TunnelDirection 

type TunnelDirection int32
const (
	DirectionKnown   TunnelDirection = 0
	DirectionForward TunnelDirection = 1
	DirectionReverse TunnelDirection = 2
)

func (TunnelDirection) EnumDescriptor 

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

func (TunnelDirection) String 

func (x TunnelDirection) String() string

Source Files

View all Source files

Directories

Path Synopsis
File: service.go Created by: Hoven Created on: 2024-11-19
 File: service.go Created by: Hoven Created on: 2024-11-19

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.