gateway

package
v0.87.0 Latest Latest
Warning

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

 Go to latest Published: Jun 5, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Predicate_gateway_sendDataToGateway = "gateway_sendDataToGateway"
)

Variables

View Source 
var (
	ErrInvalidLengthGatewayTl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGatewayTl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGatewayTl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var TLConstructor_name = map[int32]string{
	0:         "CRC32_UNKNOWN",
	645953552: "CRC32_gateway_sendDataToGateway",
}
View Source 
var TLConstructor_value = map[string]int32{
	"CRC32_UNKNOWN":                   0,
	"CRC32_gateway_sendDataToGateway": 645953552,
}

Functions

func CheckClassID 

func CheckClassID(classId int32) (ok bool)

func GetClazzID 

func GetClazzID(clazzName string, layer int) int32

func GetRPCContextRegisters 

func GetRPCContextRegisters() map[string]RPCContextTuple

func NewTLObjectByClassID 

func NewTLObjectByClassID(classId int32) mtproto.TLObject

func RegisterRPCGatewayServer 

func RegisterRPCGatewayServer(s *grpc.Server, srv RPCGatewayServer)

Types

type RPCContextTuple 

type RPCContextTuple struct {
	Method       string
	NewReplyFunc newRPCReplyFunc
}

func FindRPCContextTuple 

func FindRPCContextTuple(t interface{}) *RPCContextTuple

type RPCGatewayClient 

type RPCGatewayClient interface {
	// gateway.sendDataToGateway auth_key_id:long session_id:long payload:bytes = Bool;
	GatewaySendDataToGateway(ctx context.Context, in *TLGatewaySendDataToGateway, opts ...grpc.CallOption) (*mtproto.Bool, error)
}

RPCGatewayClient is the client API for RPCGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRPCGatewayClient 

func NewRPCGatewayClient(cc *grpc.ClientConn) RPCGatewayClient

type RPCGatewayServer 

type RPCGatewayServer interface {
	// gateway.sendDataToGateway auth_key_id:long session_id:long payload:bytes = Bool;
	GatewaySendDataToGateway(context.Context, *TLGatewaySendDataToGateway) (*mtproto.Bool, error)
}

RPCGatewayServer is the server API for RPCGateway service.

type TLConstructor 

type TLConstructor int32
const (
	CRC32_UNKNOWN                   TLConstructor = 0
	CRC32_gateway_sendDataToGateway TLConstructor = 645953552
)

func (TLConstructor) EnumDescriptor 

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

func (TLConstructor) String 

func (x TLConstructor) String() string

type TLGatewaySendDataToGateway 

type TLGatewaySendDataToGateway struct {
	Constructor          TLConstructor `protobuf:"varint,1,opt,name=constructor,proto3,enum=gateway.TLConstructor" json:"constructor,omitempty"`
	AuthKeyId            int64         `protobuf:"varint,3,opt,name=auth_key_id,json=authKeyId,proto3" json:"auth_key_id,omitempty"`
	SessionId            int64         `protobuf:"varint,4,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Payload              []byte        `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

-------------------------------------------------------------------------------------------- gateway.sendDataToGateway auth_key_id:long session_id:long payload:bytes = Bool;

func (*TLGatewaySendDataToGateway) CalcByteSize 

func (m *TLGatewaySendDataToGateway) CalcByteSize(layer int32) int

func (*TLGatewaySendDataToGateway) DebugString 

func (m *TLGatewaySendDataToGateway) DebugString() string

func (*TLGatewaySendDataToGateway) Decode 

func (m *TLGatewaySendDataToGateway) Decode(dBuf *mtproto.DecodeBuf) error

func (*TLGatewaySendDataToGateway) Descriptor 

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

func (*TLGatewaySendDataToGateway) Encode 

func (m *TLGatewaySendDataToGateway) Encode(layer int32) []byte

---------------------------------------------------------------------------------------------------------------- TLGatewaySendDataToGateway /////////////////////////////////////////////////////////////////////////////

func (*TLGatewaySendDataToGateway) GetAuthKeyId 

func (m *TLGatewaySendDataToGateway) GetAuthKeyId() int64

func (*TLGatewaySendDataToGateway) GetConstructor 

func (m *TLGatewaySendDataToGateway) GetConstructor() TLConstructor

func (*TLGatewaySendDataToGateway) GetPayload 

func (m *TLGatewaySendDataToGateway) GetPayload() []byte

func (*TLGatewaySendDataToGateway) GetSessionId 

func (m *TLGatewaySendDataToGateway) GetSessionId() int64

func (*TLGatewaySendDataToGateway) GoString 

func (this *TLGatewaySendDataToGateway) GoString() string

func (*TLGatewaySendDataToGateway) Marshal 

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

func (*TLGatewaySendDataToGateway) MarshalTo 

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

func (*TLGatewaySendDataToGateway) MarshalToSizedBuffer 

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

func (*TLGatewaySendDataToGateway) ProtoMessage 

func (*TLGatewaySendDataToGateway) ProtoMessage()

func (*TLGatewaySendDataToGateway) Reset 

func (m *TLGatewaySendDataToGateway) Reset()

func (*TLGatewaySendDataToGateway) Size 

func (m *TLGatewaySendDataToGateway) Size() (n int)

func (*TLGatewaySendDataToGateway) String 

func (m *TLGatewaySendDataToGateway) String() string

func (*TLGatewaySendDataToGateway) Unmarshal 

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

func (*TLGatewaySendDataToGateway) XXX_DiscardUnknown 

func (m *TLGatewaySendDataToGateway) XXX_DiscardUnknown()

func (*TLGatewaySendDataToGateway) XXX_Marshal 

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

func (*TLGatewaySendDataToGateway) XXX_Merge 

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

func (*TLGatewaySendDataToGateway) XXX_Size 

func (m *TLGatewaySendDataToGateway) XXX_Size() int

func (*TLGatewaySendDataToGateway) XXX_Unmarshal 

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

type UnimplementedRPCGatewayServer 

type UnimplementedRPCGatewayServer struct {
}

UnimplementedRPCGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCGatewayServer) GatewaySendDataToGateway 

func (*UnimplementedRPCGatewayServer) GatewaySendDataToGateway(ctx context.Context, req *TLGatewaySendDataToGateway) (*mtproto.Bool, error)

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.