tunneler

package
v0.0.0-...-4baaf41 Latest Latest
Warning

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

 Go to latest Published: Dec 22, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GetTunnelRequest_Base_DEFAULT *base.Base
View Source 
var GetTunnelRequest_Pubkey_DEFAULT string
View Source 
var GetTunnelResponse_BaseResp_DEFAULT *base.BaseResp
View Source 
var KitexUnusedProtection = struct{}{}

KitexUnusedProtection is used to prevent 'imported and not used' error.

Functions

This section is empty.

Types

type AuthData 

type AuthData struct {
	Authkey string `thrift:"authkey,1,required" frugal:"1,required,string" json:"authkey"`
}
var GetTunnelRequest_Auth_DEFAULT *AuthData

func NewAuthData 

func NewAuthData() *AuthData

func (*AuthData) BLength 

func (p *AuthData) BLength() int

func (*AuthData) DeepEqual 

func (p *AuthData) DeepEqual(ano *AuthData) bool

func (*AuthData) FastRead 

func (p *AuthData) FastRead(buf []byte) (int, error)

func (*AuthData) FastReadField1 

func (p *AuthData) FastReadField1(buf []byte) (int, error)

func (*AuthData) FastWrite 

func (p *AuthData) FastWrite(buf []byte) int

for compatibility

func (*AuthData) FastWriteNocopy 

func (p *AuthData) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*AuthData) Field1DeepEqual 

func (p *AuthData) Field1DeepEqual(src string) bool

func (*AuthData) GetAuthkey 

func (p *AuthData) GetAuthkey() (v string)

func (*AuthData) InitDefault 

func (p *AuthData) InitDefault()

func (*AuthData) Read 

func (p *AuthData) Read(iprot thrift.TProtocol) (err error)

func (*AuthData) ReadField1 

func (p *AuthData) ReadField1(iprot thrift.TProtocol) error

func (*AuthData) SetAuthkey 

func (p *AuthData) SetAuthkey(val string)

func (*AuthData) String 

func (p *AuthData) String() string

func (*AuthData) Write 

func (p *AuthData) Write(oprot thrift.TProtocol) (err error)

type GetTunnelRequest 

type GetTunnelRequest struct {
	Pubkey *string    `thrift:"pubkey,1,optional" frugal:"1,optional,string" json:"pubkey,omitempty"`
	Auth   *AuthData  `thrift:"auth,254,required" frugal:"254,required,AuthData" json:"auth"`
	Base   *base.Base `thrift:"Base,255" frugal:"255,default,base.Base" json:"Base"`
}
var TunnelServiceGetTunnelArgs_Req_DEFAULT *GetTunnelRequest

func NewGetTunnelRequest 

func NewGetTunnelRequest() *GetTunnelRequest

func (*GetTunnelRequest) BLength 

func (p *GetTunnelRequest) BLength() int

func (*GetTunnelRequest) DeepEqual 

func (p *GetTunnelRequest) DeepEqual(ano *GetTunnelRequest) bool

func (*GetTunnelRequest) FastRead 

func (p *GetTunnelRequest) FastRead(buf []byte) (int, error)

func (*GetTunnelRequest) FastReadField1 

func (p *GetTunnelRequest) FastReadField1(buf []byte) (int, error)

func (*GetTunnelRequest) FastReadField254 

func (p *GetTunnelRequest) FastReadField254(buf []byte) (int, error)

func (*GetTunnelRequest) FastReadField255 

func (p *GetTunnelRequest) FastReadField255(buf []byte) (int, error)

func (*GetTunnelRequest) FastWrite 

func (p *GetTunnelRequest) FastWrite(buf []byte) int

for compatibility

func (*GetTunnelRequest) FastWriteNocopy 

func (p *GetTunnelRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*GetTunnelRequest) Field1DeepEqual 

func (p *GetTunnelRequest) Field1DeepEqual(src *string) bool

func (*GetTunnelRequest) Field254DeepEqual 

func (p *GetTunnelRequest) Field254DeepEqual(src *AuthData) bool

func (*GetTunnelRequest) Field255DeepEqual 

func (p *GetTunnelRequest) Field255DeepEqual(src *base.Base) bool

func (*GetTunnelRequest) GetAuth 

func (p *GetTunnelRequest) GetAuth() (v *AuthData)

func (*GetTunnelRequest) GetBase 

func (p *GetTunnelRequest) GetBase() (v *base.Base)

func (*GetTunnelRequest) GetPubkey 

func (p *GetTunnelRequest) GetPubkey() (v string)

func (*GetTunnelRequest) InitDefault 

func (p *GetTunnelRequest) InitDefault()

func (*GetTunnelRequest) IsSetAuth 

func (p *GetTunnelRequest) IsSetAuth() bool

func (*GetTunnelRequest) IsSetBase 

func (p *GetTunnelRequest) IsSetBase() bool

func (*GetTunnelRequest) IsSetPubkey 

func (p *GetTunnelRequest) IsSetPubkey() bool

func (*GetTunnelRequest) Read 

func (p *GetTunnelRequest) Read(iprot thrift.TProtocol) (err error)

func (*GetTunnelRequest) ReadField1 

func (p *GetTunnelRequest) ReadField1(iprot thrift.TProtocol) error

func (*GetTunnelRequest) ReadField254 

func (p *GetTunnelRequest) ReadField254(iprot thrift.TProtocol) error

func (*GetTunnelRequest) ReadField255 

func (p *GetTunnelRequest) ReadField255(iprot thrift.TProtocol) error

func (*GetTunnelRequest) SetAuth 

func (p *GetTunnelRequest) SetAuth(val *AuthData)

func (*GetTunnelRequest) SetBase 

func (p *GetTunnelRequest) SetBase(val *base.Base)

func (*GetTunnelRequest) SetPubkey 

func (p *GetTunnelRequest) SetPubkey(val *string)

func (*GetTunnelRequest) String 

func (p *GetTunnelRequest) String() string

func (*GetTunnelRequest) Write 

func (p *GetTunnelRequest) Write(oprot thrift.TProtocol) (err error)

type GetTunnelResponse 

type GetTunnelResponse struct {
	Endpoint string         `thrift:"endpoint,1,required" frugal:"1,required,string" json:"endpoint"`
	BaseResp *base.BaseResp `thrift:"BaseResp,255" frugal:"255,default,base.BaseResp" json:"BaseResp"`
}
var TunnelServiceGetTunnelResult_Success_DEFAULT *GetTunnelResponse

func NewGetTunnelResponse 

func NewGetTunnelResponse() *GetTunnelResponse

func (*GetTunnelResponse) BLength 

func (p *GetTunnelResponse) BLength() int

func (*GetTunnelResponse) DeepEqual 

func (p *GetTunnelResponse) DeepEqual(ano *GetTunnelResponse) bool

func (*GetTunnelResponse) FastRead 

func (p *GetTunnelResponse) FastRead(buf []byte) (int, error)

func (*GetTunnelResponse) FastReadField1 

func (p *GetTunnelResponse) FastReadField1(buf []byte) (int, error)

func (*GetTunnelResponse) FastReadField255 

func (p *GetTunnelResponse) FastReadField255(buf []byte) (int, error)

func (*GetTunnelResponse) FastWrite 

func (p *GetTunnelResponse) FastWrite(buf []byte) int

for compatibility

func (*GetTunnelResponse) FastWriteNocopy 

func (p *GetTunnelResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*GetTunnelResponse) Field1DeepEqual 

func (p *GetTunnelResponse) Field1DeepEqual(src string) bool

func (*GetTunnelResponse) Field255DeepEqual 

func (p *GetTunnelResponse) Field255DeepEqual(src *base.BaseResp) bool

func (*GetTunnelResponse) GetBaseResp 

func (p *GetTunnelResponse) GetBaseResp() (v *base.BaseResp)

func (*GetTunnelResponse) GetEndpoint 

func (p *GetTunnelResponse) GetEndpoint() (v string)

func (*GetTunnelResponse) InitDefault 

func (p *GetTunnelResponse) InitDefault()

func (*GetTunnelResponse) IsSetBaseResp 

func (p *GetTunnelResponse) IsSetBaseResp() bool

func (*GetTunnelResponse) Read 

func (p *GetTunnelResponse) Read(iprot thrift.TProtocol) (err error)

func (*GetTunnelResponse) ReadField1 

func (p *GetTunnelResponse) ReadField1(iprot thrift.TProtocol) error

func (*GetTunnelResponse) ReadField255 

func (p *GetTunnelResponse) ReadField255(iprot thrift.TProtocol) error

func (*GetTunnelResponse) SetBaseResp 

func (p *GetTunnelResponse) SetBaseResp(val *base.BaseResp)

func (*GetTunnelResponse) SetEndpoint 

func (p *GetTunnelResponse) SetEndpoint(val string)

func (*GetTunnelResponse) String 

func (p *GetTunnelResponse) String() string

func (*GetTunnelResponse) Write 

func (p *GetTunnelResponse) Write(oprot thrift.TProtocol) (err error)

type Tunnel 

type Tunnel struct {
	Id int64 `thrift:"id,1,required" frugal:"1,required,i64" json:"id"`
}

func NewTunnel 

func NewTunnel() *Tunnel

func (*Tunnel) BLength 

func (p *Tunnel) BLength() int

func (*Tunnel) DeepEqual 

func (p *Tunnel) DeepEqual(ano *Tunnel) bool

func (*Tunnel) FastRead 

func (p *Tunnel) FastRead(buf []byte) (int, error)

func (*Tunnel) FastReadField1 

func (p *Tunnel) FastReadField1(buf []byte) (int, error)

func (*Tunnel) FastWrite 

func (p *Tunnel) FastWrite(buf []byte) int

for compatibility

func (*Tunnel) FastWriteNocopy 

func (p *Tunnel) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*Tunnel) Field1DeepEqual 

func (p *Tunnel) Field1DeepEqual(src int64) bool

func (*Tunnel) GetId 

func (p *Tunnel) GetId() (v int64)

func (*Tunnel) InitDefault 

func (p *Tunnel) InitDefault()

func (*Tunnel) Read 

func (p *Tunnel) Read(iprot thrift.TProtocol) (err error)

func (*Tunnel) ReadField1 

func (p *Tunnel) ReadField1(iprot thrift.TProtocol) error

func (*Tunnel) SetId 

func (p *Tunnel) SetId(val int64)

func (*Tunnel) String 

func (p *Tunnel) String() string

func (*Tunnel) Write 

func (p *Tunnel) Write(oprot thrift.TProtocol) (err error)

type TunnelService 

type TunnelService interface {
	GetTunnel(ctx context.Context, req *GetTunnelRequest) (r *GetTunnelResponse, err error)
}

type TunnelServiceClient 

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

func NewTunnelServiceClient 

func NewTunnelServiceClient(c thrift.TClient) *TunnelServiceClient

func NewTunnelServiceClientFactory 

func NewTunnelServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TunnelServiceClient

func NewTunnelServiceClientProtocol 

func NewTunnelServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TunnelServiceClient

func (*TunnelServiceClient) Client_ 

func (p *TunnelServiceClient) Client_() thrift.TClient

func (*TunnelServiceClient) GetTunnel 

func (p *TunnelServiceClient) GetTunnel(ctx context.Context, req *GetTunnelRequest) (r *GetTunnelResponse, err error)

type TunnelServiceGetTunnelArgs 

type TunnelServiceGetTunnelArgs struct {
	Req *GetTunnelRequest `thrift:"req,1" frugal:"1,default,GetTunnelRequest" json:"req"`
}

func NewTunnelServiceGetTunnelArgs 

func NewTunnelServiceGetTunnelArgs() *TunnelServiceGetTunnelArgs

func (*TunnelServiceGetTunnelArgs) BLength 

func (p *TunnelServiceGetTunnelArgs) BLength() int

func (*TunnelServiceGetTunnelArgs) DeepEqual 

func (p *TunnelServiceGetTunnelArgs) DeepEqual(ano *TunnelServiceGetTunnelArgs) bool

func (*TunnelServiceGetTunnelArgs) FastRead 

func (p *TunnelServiceGetTunnelArgs) FastRead(buf []byte) (int, error)

func (*TunnelServiceGetTunnelArgs) FastReadField1 

func (p *TunnelServiceGetTunnelArgs) FastReadField1(buf []byte) (int, error)

func (*TunnelServiceGetTunnelArgs) FastWrite 

func (p *TunnelServiceGetTunnelArgs) FastWrite(buf []byte) int

for compatibility

func (*TunnelServiceGetTunnelArgs) FastWriteNocopy 

func (p *TunnelServiceGetTunnelArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TunnelServiceGetTunnelArgs) Field1DeepEqual 

func (p *TunnelServiceGetTunnelArgs) Field1DeepEqual(src *GetTunnelRequest) bool

func (*TunnelServiceGetTunnelArgs) GetFirstArgument 

func (p *TunnelServiceGetTunnelArgs) GetFirstArgument() interface{}

func (*TunnelServiceGetTunnelArgs) GetReq 

func (p *TunnelServiceGetTunnelArgs) GetReq() (v *GetTunnelRequest)

func (*TunnelServiceGetTunnelArgs) InitDefault 

func (p *TunnelServiceGetTunnelArgs) InitDefault()

func (*TunnelServiceGetTunnelArgs) IsSetReq 

func (p *TunnelServiceGetTunnelArgs) IsSetReq() bool

func (*TunnelServiceGetTunnelArgs) Read 

func (p *TunnelServiceGetTunnelArgs) Read(iprot thrift.TProtocol) (err error)

func (*TunnelServiceGetTunnelArgs) ReadField1 

func (p *TunnelServiceGetTunnelArgs) ReadField1(iprot thrift.TProtocol) error

func (*TunnelServiceGetTunnelArgs) SetReq 

func (p *TunnelServiceGetTunnelArgs) SetReq(val *GetTunnelRequest)

func (*TunnelServiceGetTunnelArgs) String 

func (p *TunnelServiceGetTunnelArgs) String() string

func (*TunnelServiceGetTunnelArgs) Write 

func (p *TunnelServiceGetTunnelArgs) Write(oprot thrift.TProtocol) (err error)

type TunnelServiceGetTunnelResult 

type TunnelServiceGetTunnelResult struct {
	Success *GetTunnelResponse `thrift:"success,0,optional" frugal:"0,optional,GetTunnelResponse" json:"success,omitempty"`
}

func NewTunnelServiceGetTunnelResult 

func NewTunnelServiceGetTunnelResult() *TunnelServiceGetTunnelResult

func (*TunnelServiceGetTunnelResult) BLength 

func (p *TunnelServiceGetTunnelResult) BLength() int

func (*TunnelServiceGetTunnelResult) DeepEqual 

func (p *TunnelServiceGetTunnelResult) DeepEqual(ano *TunnelServiceGetTunnelResult) bool

func (*TunnelServiceGetTunnelResult) FastRead 

func (p *TunnelServiceGetTunnelResult) FastRead(buf []byte) (int, error)

func (*TunnelServiceGetTunnelResult) FastReadField0 

func (p *TunnelServiceGetTunnelResult) FastReadField0(buf []byte) (int, error)

func (*TunnelServiceGetTunnelResult) FastWrite 

func (p *TunnelServiceGetTunnelResult) FastWrite(buf []byte) int

for compatibility

func (*TunnelServiceGetTunnelResult) FastWriteNocopy 

func (p *TunnelServiceGetTunnelResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*TunnelServiceGetTunnelResult) Field0DeepEqual 

func (p *TunnelServiceGetTunnelResult) Field0DeepEqual(src *GetTunnelResponse) bool

func (*TunnelServiceGetTunnelResult) GetResult 

func (p *TunnelServiceGetTunnelResult) GetResult() interface{}

func (*TunnelServiceGetTunnelResult) GetSuccess 

func (p *TunnelServiceGetTunnelResult) GetSuccess() (v *GetTunnelResponse)

func (*TunnelServiceGetTunnelResult) InitDefault 

func (p *TunnelServiceGetTunnelResult) InitDefault()

func (*TunnelServiceGetTunnelResult) IsSetSuccess 

func (p *TunnelServiceGetTunnelResult) IsSetSuccess() bool

func (*TunnelServiceGetTunnelResult) Read 

func (p *TunnelServiceGetTunnelResult) Read(iprot thrift.TProtocol) (err error)

func (*TunnelServiceGetTunnelResult) ReadField0 

func (p *TunnelServiceGetTunnelResult) ReadField0(iprot thrift.TProtocol) error

func (*TunnelServiceGetTunnelResult) SetSuccess 

func (p *TunnelServiceGetTunnelResult) SetSuccess(x interface{})

func (*TunnelServiceGetTunnelResult) String 

func (p *TunnelServiceGetTunnelResult) String() string

func (*TunnelServiceGetTunnelResult) Write 

func (p *TunnelServiceGetTunnelResult) Write(oprot thrift.TProtocol) (err error)

type TunnelServiceProcessor 

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

func NewTunnelServiceProcessor 

func NewTunnelServiceProcessor(handler TunnelService) *TunnelServiceProcessor

func (*TunnelServiceProcessor) AddToProcessorMap 

func (p *TunnelServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*TunnelServiceProcessor) GetProcessorFunction 

func (p *TunnelServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*TunnelServiceProcessor) Process 

func (p *TunnelServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*TunnelServiceProcessor) ProcessorMap 

func (p *TunnelServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

Source Files

View all Source files

Directories

Path Synopsis
Code generated by Kitex v0.4.4.
 Code generated by Kitex v0.4.4.

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.