sync

package
v0.96.0 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Predicate_sync_updatesMe        = "sync_updatesMe"
	Predicate_sync_updatesNotMe     = "sync_updatesNotMe"
	Predicate_sync_pushUpdates      = "sync_pushUpdates"
	Predicate_sync_pushUpdatesIfNot = "sync_pushUpdatesIfNot"
	Predicate_sync_pushBotUpdates   = "sync_pushBotUpdates"
	Predicate_sync_pushRpcResult    = "sync_pushRpcResult"
	Predicate_sync_broadcastUpdates = "sync_broadcastUpdates"
)
View Source 
const (
	BroadcastTypeChat            = 1
	BroadcastTypeChannel         = 2
	BroadcastTypeChannelAdmin    = 3
	BroadcastTypeChannelNotAdmin = 4
)

Variables

View Source 
var (
	ErrInvalidLengthSyncTl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSyncTl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSyncTl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var TLConstructor_name = map[int32]string{
	0:           "CRC32_UNKNOWN",
	1614568688:  "CRC32_sync_updatesMe",
	16458447:    "CRC32_sync_updatesNotMe",
	-1895114306: "CRC32_sync_pushUpdates",
	1074085860:  "CRC32_sync_pushUpdatesIfNot",
	-1379667968: "CRC32_sync_pushBotUpdates",
	-1874085983: "CRC32_sync_pushRpcResult",
	-169648970:  "CRC32_sync_broadcastUpdates",
}
View Source 
var TLConstructor_value = map[string]int32{
	"CRC32_UNKNOWN":               0,
	"CRC32_sync_updatesMe":        1614568688,
	"CRC32_sync_updatesNotMe":     16458447,
	"CRC32_sync_pushUpdates":      -1895114306,
	"CRC32_sync_pushUpdatesIfNot": 1074085860,
	"CRC32_sync_pushBotUpdates":   -1379667968,
	"CRC32_sync_pushRpcResult":    -1874085983,
	"CRC32_sync_broadcastUpdates": -169648970,
}

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 RegisterRPCSyncServer 

func RegisterRPCSyncServer(s *grpc.Server, srv RPCSyncServer)

Types

type RPCContextTuple 

type RPCContextTuple struct {
	Method       string
	NewReplyFunc newRPCReplyFunc
}

func FindRPCContextTuple 

func FindRPCContextTuple(t interface{}) *RPCContextTuple

type RPCSyncClient 

type RPCSyncClient interface {
	// sync.updatesMe flags:# user_id:long auth_key_id:long server_id:string session_id:flags.0?long updates:Updates = Void;
	SyncUpdatesMe(ctx context.Context, in *TLSyncUpdatesMe, opts ...grpc.CallOption) (*mtproto.Void, error)
	// sync.updatesNotMe user_id:long auth_key_id:long updates:Updates = Void;
	SyncUpdatesNotMe(ctx context.Context, in *TLSyncUpdatesNotMe, opts ...grpc.CallOption) (*mtproto.Void, error)
	// sync.pushUpdates user_id:long updates:Updates = Void;
	SyncPushUpdates(ctx context.Context, in *TLSyncPushUpdates, opts ...grpc.CallOption) (*mtproto.Void, error)
	// sync.pushUpdatesIfNot user_id:long excludes:Vector<long> updates:Updates = Void;
	SyncPushUpdatesIfNot(ctx context.Context, in *TLSyncPushUpdatesIfNot, opts ...grpc.CallOption) (*mtproto.Void, error)
	// sync.pushBotUpdates user_id:long updates:Updates = Void;
	SyncPushBotUpdates(ctx context.Context, in *TLSyncPushBotUpdates, opts ...grpc.CallOption) (*mtproto.Void, error)
	// sync.pushRpcResult auth_key_id:long server_id:string session_id:long client_req_msg_id:long rpc_result:bytes = Void;
	SyncPushRpcResult(ctx context.Context, in *TLSyncPushRpcResult, opts ...grpc.CallOption) (*mtproto.Void, error)
	// sync.broadcastUpdates broadcast_type:int chat_id:long exclude_id_list:Vector<long> updates:Updates = Void;
	SyncBroadcastUpdates(ctx context.Context, in *TLSyncBroadcastUpdates, opts ...grpc.CallOption) (*mtproto.Void, error)
}

RPCSyncClient is the client API for RPCSync service.

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

func NewRPCSyncClient 

func NewRPCSyncClient(cc *grpc.ClientConn) RPCSyncClient

type RPCSyncServer 

type RPCSyncServer interface {
	// sync.updatesMe flags:# user_id:long auth_key_id:long server_id:string session_id:flags.0?long updates:Updates = Void;
	SyncUpdatesMe(context.Context, *TLSyncUpdatesMe) (*mtproto.Void, error)
	// sync.updatesNotMe user_id:long auth_key_id:long updates:Updates = Void;
	SyncUpdatesNotMe(context.Context, *TLSyncUpdatesNotMe) (*mtproto.Void, error)
	// sync.pushUpdates user_id:long updates:Updates = Void;
	SyncPushUpdates(context.Context, *TLSyncPushUpdates) (*mtproto.Void, error)
	// sync.pushUpdatesIfNot user_id:long excludes:Vector<long> updates:Updates = Void;
	SyncPushUpdatesIfNot(context.Context, *TLSyncPushUpdatesIfNot) (*mtproto.Void, error)
	// sync.pushBotUpdates user_id:long updates:Updates = Void;
	SyncPushBotUpdates(context.Context, *TLSyncPushBotUpdates) (*mtproto.Void, error)
	// sync.pushRpcResult auth_key_id:long server_id:string session_id:long client_req_msg_id:long rpc_result:bytes = Void;
	SyncPushRpcResult(context.Context, *TLSyncPushRpcResult) (*mtproto.Void, error)
	// sync.broadcastUpdates broadcast_type:int chat_id:long exclude_id_list:Vector<long> updates:Updates = Void;
	SyncBroadcastUpdates(context.Context, *TLSyncBroadcastUpdates) (*mtproto.Void, error)
}

RPCSyncServer is the server API for RPCSync service.

type TLConstructor 

type TLConstructor int32
const (
	CRC32_UNKNOWN               TLConstructor = 0
	CRC32_sync_updatesMe        TLConstructor = 1614568688
	CRC32_sync_updatesNotMe     TLConstructor = 16458447
	CRC32_sync_pushUpdates      TLConstructor = -1895114306
	CRC32_sync_pushUpdatesIfNot TLConstructor = 1074085860
	CRC32_sync_pushBotUpdates   TLConstructor = -1379667968
	CRC32_sync_pushRpcResult    TLConstructor = -1874085983
	CRC32_sync_broadcastUpdates TLConstructor = -169648970
)

func (TLConstructor) EnumDescriptor 

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

func (TLConstructor) String 

func (x TLConstructor) String() string

type TLSyncBroadcastUpdates 

type TLSyncBroadcastUpdates struct {
	Constructor          TLConstructor    `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	BroadcastType        int32            `protobuf:"varint,3,opt,name=broadcast_type,json=broadcastType,proto3" json:"broadcast_type,omitempty"`
	ChatId               int64            `protobuf:"varint,4,opt,name=chat_id,json=chatId,proto3" json:"chat_id,omitempty"`
	ExcludeIdList        []int64          `protobuf:"varint,5,rep,packed,name=exclude_id_list,json=excludeIdList,proto3" json:"exclude_id_list,omitempty"`
	Updates              *mtproto.Updates `protobuf:"bytes,6,opt,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.broadcastUpdates broadcast_type:int chat_id:long exclude_id_list:Vector<long> updates:Updates = Void;

func (*TLSyncBroadcastUpdates) CalcByteSize 

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

func (*TLSyncBroadcastUpdates) DebugString 

func (m *TLSyncBroadcastUpdates) DebugString() string

func (*TLSyncBroadcastUpdates) Decode 

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

func (*TLSyncBroadcastUpdates) Descriptor 

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

func (*TLSyncBroadcastUpdates) Encode 

func (m *TLSyncBroadcastUpdates) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncBroadcastUpdates) GetBroadcastType 

func (m *TLSyncBroadcastUpdates) GetBroadcastType() int32

func (*TLSyncBroadcastUpdates) GetChatId 

func (m *TLSyncBroadcastUpdates) GetChatId() int64

func (*TLSyncBroadcastUpdates) GetConstructor 

func (m *TLSyncBroadcastUpdates) GetConstructor() TLConstructor

func (*TLSyncBroadcastUpdates) GetExcludeIdList 

func (m *TLSyncBroadcastUpdates) GetExcludeIdList() []int64

func (*TLSyncBroadcastUpdates) GetUpdates 

func (m *TLSyncBroadcastUpdates) GetUpdates() *mtproto.Updates

func (*TLSyncBroadcastUpdates) GoString 

func (this *TLSyncBroadcastUpdates) GoString() string

func (*TLSyncBroadcastUpdates) Marshal 

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

func (*TLSyncBroadcastUpdates) MarshalTo 

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

func (*TLSyncBroadcastUpdates) MarshalToSizedBuffer 

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

func (*TLSyncBroadcastUpdates) ProtoMessage 

func (*TLSyncBroadcastUpdates) ProtoMessage()

func (*TLSyncBroadcastUpdates) Reset 

func (m *TLSyncBroadcastUpdates) Reset()

func (*TLSyncBroadcastUpdates) Size 

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

func (*TLSyncBroadcastUpdates) String 

func (m *TLSyncBroadcastUpdates) String() string

func (*TLSyncBroadcastUpdates) Unmarshal 

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

func (*TLSyncBroadcastUpdates) XXX_DiscardUnknown 

func (m *TLSyncBroadcastUpdates) XXX_DiscardUnknown()

func (*TLSyncBroadcastUpdates) XXX_Marshal 

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

func (*TLSyncBroadcastUpdates) XXX_Merge 

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

func (*TLSyncBroadcastUpdates) XXX_Size 

func (m *TLSyncBroadcastUpdates) XXX_Size() int

func (*TLSyncBroadcastUpdates) XXX_Unmarshal 

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

type TLSyncPushBotUpdates 

type TLSyncPushBotUpdates struct {
	Constructor          TLConstructor    `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	UserId               int64            `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Updates              *mtproto.Updates `protobuf:"bytes,4,opt,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.pushBotUpdates user_id:long updates:Updates = Void;

func (*TLSyncPushBotUpdates) CalcByteSize 

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

func (*TLSyncPushBotUpdates) DebugString 

func (m *TLSyncPushBotUpdates) DebugString() string

func (*TLSyncPushBotUpdates) Decode 

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

func (*TLSyncPushBotUpdates) Descriptor 

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

func (*TLSyncPushBotUpdates) Encode 

func (m *TLSyncPushBotUpdates) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncPushBotUpdates) GetConstructor 

func (m *TLSyncPushBotUpdates) GetConstructor() TLConstructor

func (*TLSyncPushBotUpdates) GetUpdates 

func (m *TLSyncPushBotUpdates) GetUpdates() *mtproto.Updates

func (*TLSyncPushBotUpdates) GetUserId 

func (m *TLSyncPushBotUpdates) GetUserId() int64

func (*TLSyncPushBotUpdates) GoString 

func (this *TLSyncPushBotUpdates) GoString() string

func (*TLSyncPushBotUpdates) Marshal 

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

func (*TLSyncPushBotUpdates) MarshalTo 

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

func (*TLSyncPushBotUpdates) MarshalToSizedBuffer 

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

func (*TLSyncPushBotUpdates) ProtoMessage 

func (*TLSyncPushBotUpdates) ProtoMessage()

func (*TLSyncPushBotUpdates) Reset 

func (m *TLSyncPushBotUpdates) Reset()

func (*TLSyncPushBotUpdates) Size 

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

func (*TLSyncPushBotUpdates) String 

func (m *TLSyncPushBotUpdates) String() string

func (*TLSyncPushBotUpdates) Unmarshal 

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

func (*TLSyncPushBotUpdates) XXX_DiscardUnknown 

func (m *TLSyncPushBotUpdates) XXX_DiscardUnknown()

func (*TLSyncPushBotUpdates) XXX_Marshal 

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

func (*TLSyncPushBotUpdates) XXX_Merge 

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

func (*TLSyncPushBotUpdates) XXX_Size 

func (m *TLSyncPushBotUpdates) XXX_Size() int

func (*TLSyncPushBotUpdates) XXX_Unmarshal 

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

type TLSyncPushRpcResult 

type TLSyncPushRpcResult struct {
	Constructor          TLConstructor `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	AuthKeyId            int64         `protobuf:"varint,3,opt,name=auth_key_id,json=authKeyId,proto3" json:"auth_key_id,omitempty"`
	ServerId             string        `protobuf:"bytes,4,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	SessionId            int64         `protobuf:"varint,5,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	ClientReqMsgId       int64         `protobuf:"varint,6,opt,name=client_req_msg_id,json=clientReqMsgId,proto3" json:"client_req_msg_id,omitempty"`
	RpcResult            []byte        `protobuf:"bytes,7,opt,name=rpc_result,json=rpcResult,proto3" json:"rpc_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.pushRpcResult auth_key_id:long server_id:string session_id:long client_req_msg_id:long rpc_result:bytes = Void;

func (*TLSyncPushRpcResult) CalcByteSize 

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

func (*TLSyncPushRpcResult) DebugString 

func (m *TLSyncPushRpcResult) DebugString() string

func (*TLSyncPushRpcResult) Decode 

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

func (*TLSyncPushRpcResult) Descriptor 

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

func (*TLSyncPushRpcResult) Encode 

func (m *TLSyncPushRpcResult) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncPushRpcResult) GetAuthKeyId 

func (m *TLSyncPushRpcResult) GetAuthKeyId() int64

func (*TLSyncPushRpcResult) GetClientReqMsgId 

func (m *TLSyncPushRpcResult) GetClientReqMsgId() int64

func (*TLSyncPushRpcResult) GetConstructor 

func (m *TLSyncPushRpcResult) GetConstructor() TLConstructor

func (*TLSyncPushRpcResult) GetRpcResult 

func (m *TLSyncPushRpcResult) GetRpcResult() []byte

func (*TLSyncPushRpcResult) GetServerId 

func (m *TLSyncPushRpcResult) GetServerId() string

func (*TLSyncPushRpcResult) GetSessionId 

func (m *TLSyncPushRpcResult) GetSessionId() int64

func (*TLSyncPushRpcResult) GoString 

func (this *TLSyncPushRpcResult) GoString() string

func (*TLSyncPushRpcResult) Marshal 

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

func (*TLSyncPushRpcResult) MarshalTo 

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

func (*TLSyncPushRpcResult) MarshalToSizedBuffer 

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

func (*TLSyncPushRpcResult) ProtoMessage 

func (*TLSyncPushRpcResult) ProtoMessage()

func (*TLSyncPushRpcResult) Reset 

func (m *TLSyncPushRpcResult) Reset()

func (*TLSyncPushRpcResult) Size 

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

func (*TLSyncPushRpcResult) String 

func (m *TLSyncPushRpcResult) String() string

func (*TLSyncPushRpcResult) Unmarshal 

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

func (*TLSyncPushRpcResult) XXX_DiscardUnknown 

func (m *TLSyncPushRpcResult) XXX_DiscardUnknown()

func (*TLSyncPushRpcResult) XXX_Marshal 

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

func (*TLSyncPushRpcResult) XXX_Merge 

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

func (*TLSyncPushRpcResult) XXX_Size 

func (m *TLSyncPushRpcResult) XXX_Size() int

func (*TLSyncPushRpcResult) XXX_Unmarshal 

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

type TLSyncPushUpdates 

type TLSyncPushUpdates struct {
	Constructor          TLConstructor    `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	UserId               int64            `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Updates              *mtproto.Updates `protobuf:"bytes,4,opt,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.pushUpdates user_id:long updates:Updates = Void;

func (*TLSyncPushUpdates) CalcByteSize 

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

func (*TLSyncPushUpdates) DebugString 

func (m *TLSyncPushUpdates) DebugString() string

func (*TLSyncPushUpdates) Decode 

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

func (*TLSyncPushUpdates) Descriptor 

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

func (*TLSyncPushUpdates) Encode 

func (m *TLSyncPushUpdates) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncPushUpdates) GetConstructor 

func (m *TLSyncPushUpdates) GetConstructor() TLConstructor

func (*TLSyncPushUpdates) GetUpdates 

func (m *TLSyncPushUpdates) GetUpdates() *mtproto.Updates

func (*TLSyncPushUpdates) GetUserId 

func (m *TLSyncPushUpdates) GetUserId() int64

func (*TLSyncPushUpdates) GoString 

func (this *TLSyncPushUpdates) GoString() string

func (*TLSyncPushUpdates) Marshal 

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

func (*TLSyncPushUpdates) MarshalTo 

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

func (*TLSyncPushUpdates) MarshalToSizedBuffer 

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

func (*TLSyncPushUpdates) ProtoMessage 

func (*TLSyncPushUpdates) ProtoMessage()

func (*TLSyncPushUpdates) Reset 

func (m *TLSyncPushUpdates) Reset()

func (*TLSyncPushUpdates) Size 

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

func (*TLSyncPushUpdates) String 

func (m *TLSyncPushUpdates) String() string

func (*TLSyncPushUpdates) Unmarshal 

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

func (*TLSyncPushUpdates) XXX_DiscardUnknown 

func (m *TLSyncPushUpdates) XXX_DiscardUnknown()

func (*TLSyncPushUpdates) XXX_Marshal 

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

func (*TLSyncPushUpdates) XXX_Merge 

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

func (*TLSyncPushUpdates) XXX_Size 

func (m *TLSyncPushUpdates) XXX_Size() int

func (*TLSyncPushUpdates) XXX_Unmarshal 

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

type TLSyncPushUpdatesIfNot 

type TLSyncPushUpdatesIfNot struct {
	Constructor          TLConstructor    `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	UserId               int64            `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Excludes             []int64          `protobuf:"varint,4,rep,packed,name=excludes,proto3" json:"excludes,omitempty"`
	Updates              *mtproto.Updates `protobuf:"bytes,5,opt,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.pushUpdatesIfNot user_id:long excludes:Vector<long> updates:Updates = Void;

func (*TLSyncPushUpdatesIfNot) CalcByteSize 

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

func (*TLSyncPushUpdatesIfNot) DebugString 

func (m *TLSyncPushUpdatesIfNot) DebugString() string

func (*TLSyncPushUpdatesIfNot) Decode 

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

func (*TLSyncPushUpdatesIfNot) Descriptor 

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

func (*TLSyncPushUpdatesIfNot) Encode 

func (m *TLSyncPushUpdatesIfNot) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncPushUpdatesIfNot) GetConstructor 

func (m *TLSyncPushUpdatesIfNot) GetConstructor() TLConstructor

func (*TLSyncPushUpdatesIfNot) GetExcludes 

func (m *TLSyncPushUpdatesIfNot) GetExcludes() []int64

func (*TLSyncPushUpdatesIfNot) GetUpdates 

func (m *TLSyncPushUpdatesIfNot) GetUpdates() *mtproto.Updates

func (*TLSyncPushUpdatesIfNot) GetUserId 

func (m *TLSyncPushUpdatesIfNot) GetUserId() int64

func (*TLSyncPushUpdatesIfNot) GoString 

func (this *TLSyncPushUpdatesIfNot) GoString() string

func (*TLSyncPushUpdatesIfNot) Marshal 

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

func (*TLSyncPushUpdatesIfNot) MarshalTo 

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

func (*TLSyncPushUpdatesIfNot) MarshalToSizedBuffer 

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

func (*TLSyncPushUpdatesIfNot) ProtoMessage 

func (*TLSyncPushUpdatesIfNot) ProtoMessage()

func (*TLSyncPushUpdatesIfNot) Reset 

func (m *TLSyncPushUpdatesIfNot) Reset()

func (*TLSyncPushUpdatesIfNot) Size 

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

func (*TLSyncPushUpdatesIfNot) String 

func (m *TLSyncPushUpdatesIfNot) String() string

func (*TLSyncPushUpdatesIfNot) Unmarshal 

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

func (*TLSyncPushUpdatesIfNot) XXX_DiscardUnknown 

func (m *TLSyncPushUpdatesIfNot) XXX_DiscardUnknown()

func (*TLSyncPushUpdatesIfNot) XXX_Marshal 

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

func (*TLSyncPushUpdatesIfNot) XXX_Merge 

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

func (*TLSyncPushUpdatesIfNot) XXX_Size 

func (m *TLSyncPushUpdatesIfNot) XXX_Size() int

func (*TLSyncPushUpdatesIfNot) XXX_Unmarshal 

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

type TLSyncUpdatesMe 

type TLSyncUpdatesMe struct {
	Constructor          TLConstructor     `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	UserId               int64             `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	AuthKeyId            int64             `protobuf:"varint,4,opt,name=auth_key_id,json=authKeyId,proto3" json:"auth_key_id,omitempty"`
	ServerId             string            `protobuf:"bytes,5,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	SessionId            *types.Int64Value `protobuf:"bytes,6,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Updates              *mtproto.Updates  `protobuf:"bytes,7,opt,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.updatesMe flags:# user_id:long auth_key_id:long server_id:string session_id:flags.0?long updates:Updates = Void;

func (*TLSyncUpdatesMe) CalcByteSize 

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

func (*TLSyncUpdatesMe) DebugString 

func (m *TLSyncUpdatesMe) DebugString() string

func (*TLSyncUpdatesMe) Decode 

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

func (*TLSyncUpdatesMe) Descriptor 

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

func (*TLSyncUpdatesMe) Encode 

func (m *TLSyncUpdatesMe) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncUpdatesMe) GetAuthKeyId 

func (m *TLSyncUpdatesMe) GetAuthKeyId() int64

func (*TLSyncUpdatesMe) GetConstructor 

func (m *TLSyncUpdatesMe) GetConstructor() TLConstructor

func (*TLSyncUpdatesMe) GetServerId 

func (m *TLSyncUpdatesMe) GetServerId() string

func (*TLSyncUpdatesMe) GetSessionId 

func (m *TLSyncUpdatesMe) GetSessionId() *types.Int64Value

func (*TLSyncUpdatesMe) GetUpdates 

func (m *TLSyncUpdatesMe) GetUpdates() *mtproto.Updates

func (*TLSyncUpdatesMe) GetUserId 

func (m *TLSyncUpdatesMe) GetUserId() int64

func (*TLSyncUpdatesMe) GoString 

func (this *TLSyncUpdatesMe) GoString() string

func (*TLSyncUpdatesMe) Marshal 

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

func (*TLSyncUpdatesMe) MarshalTo 

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

func (*TLSyncUpdatesMe) MarshalToSizedBuffer 

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

func (*TLSyncUpdatesMe) ProtoMessage 

func (*TLSyncUpdatesMe) ProtoMessage()

func (*TLSyncUpdatesMe) Reset 

func (m *TLSyncUpdatesMe) Reset()

func (*TLSyncUpdatesMe) Size 

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

func (*TLSyncUpdatesMe) String 

func (m *TLSyncUpdatesMe) String() string

func (*TLSyncUpdatesMe) Unmarshal 

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

func (*TLSyncUpdatesMe) XXX_DiscardUnknown 

func (m *TLSyncUpdatesMe) XXX_DiscardUnknown()

func (*TLSyncUpdatesMe) XXX_Marshal 

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

func (*TLSyncUpdatesMe) XXX_Merge 

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

func (*TLSyncUpdatesMe) XXX_Size 

func (m *TLSyncUpdatesMe) XXX_Size() int

func (*TLSyncUpdatesMe) XXX_Unmarshal 

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

type TLSyncUpdatesNotMe 

type TLSyncUpdatesNotMe struct {
	Constructor          TLConstructor    `protobuf:"varint,1,opt,name=constructor,proto3,enum=sync.TLConstructor" json:"constructor,omitempty"`
	UserId               int64            `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	AuthKeyId            int64            `protobuf:"varint,4,opt,name=auth_key_id,json=authKeyId,proto3" json:"auth_key_id,omitempty"`
	Updates              *mtproto.Updates `protobuf:"bytes,5,opt,name=updates,proto3" json:"updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

-------------------------------------------------------------------------------------------- sync.updatesNotMe user_id:long auth_key_id:long updates:Updates = Void;

func (*TLSyncUpdatesNotMe) CalcByteSize 

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

func (*TLSyncUpdatesNotMe) DebugString 

func (m *TLSyncUpdatesNotMe) DebugString() string

func (*TLSyncUpdatesNotMe) Decode 

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

func (*TLSyncUpdatesNotMe) Descriptor 

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

func (*TLSyncUpdatesNotMe) Encode 

func (m *TLSyncUpdatesNotMe) Encode(x *mtproto.EncodeBuf, layer int32) error

func (*TLSyncUpdatesNotMe) GetAuthKeyId 

func (m *TLSyncUpdatesNotMe) GetAuthKeyId() int64

func (*TLSyncUpdatesNotMe) GetConstructor 

func (m *TLSyncUpdatesNotMe) GetConstructor() TLConstructor

func (*TLSyncUpdatesNotMe) GetUpdates 

func (m *TLSyncUpdatesNotMe) GetUpdates() *mtproto.Updates

func (*TLSyncUpdatesNotMe) GetUserId 

func (m *TLSyncUpdatesNotMe) GetUserId() int64

func (*TLSyncUpdatesNotMe) GoString 

func (this *TLSyncUpdatesNotMe) GoString() string

func (*TLSyncUpdatesNotMe) Marshal 

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

func (*TLSyncUpdatesNotMe) MarshalTo 

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

func (*TLSyncUpdatesNotMe) MarshalToSizedBuffer 

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

func (*TLSyncUpdatesNotMe) ProtoMessage 

func (*TLSyncUpdatesNotMe) ProtoMessage()

func (*TLSyncUpdatesNotMe) Reset 

func (m *TLSyncUpdatesNotMe) Reset()

func (*TLSyncUpdatesNotMe) Size 

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

func (*TLSyncUpdatesNotMe) String 

func (m *TLSyncUpdatesNotMe) String() string

func (*TLSyncUpdatesNotMe) Unmarshal 

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

func (*TLSyncUpdatesNotMe) XXX_DiscardUnknown 

func (m *TLSyncUpdatesNotMe) XXX_DiscardUnknown()

func (*TLSyncUpdatesNotMe) XXX_Marshal 

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

func (*TLSyncUpdatesNotMe) XXX_Merge 

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

func (*TLSyncUpdatesNotMe) XXX_Size 

func (m *TLSyncUpdatesNotMe) XXX_Size() int

func (*TLSyncUpdatesNotMe) XXX_Unmarshal 

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

type UnimplementedRPCSyncServer 

type UnimplementedRPCSyncServer struct {
}

UnimplementedRPCSyncServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCSyncServer) SyncBroadcastUpdates 

func (*UnimplementedRPCSyncServer) SyncBroadcastUpdates(ctx context.Context, req *TLSyncBroadcastUpdates) (*mtproto.Void, error)

func (*UnimplementedRPCSyncServer) SyncPushBotUpdates 

func (*UnimplementedRPCSyncServer) SyncPushBotUpdates(ctx context.Context, req *TLSyncPushBotUpdates) (*mtproto.Void, error)

func (*UnimplementedRPCSyncServer) SyncPushRpcResult 

func (*UnimplementedRPCSyncServer) SyncPushRpcResult(ctx context.Context, req *TLSyncPushRpcResult) (*mtproto.Void, error)

func (*UnimplementedRPCSyncServer) SyncPushUpdates 

func (*UnimplementedRPCSyncServer) SyncPushUpdates(ctx context.Context, req *TLSyncPushUpdates) (*mtproto.Void, error)

func (*UnimplementedRPCSyncServer) SyncPushUpdatesIfNot 

func (*UnimplementedRPCSyncServer) SyncPushUpdatesIfNot(ctx context.Context, req *TLSyncPushUpdatesIfNot) (*mtproto.Void, error)

func (*UnimplementedRPCSyncServer) SyncUpdatesMe 

func (*UnimplementedRPCSyncServer) SyncUpdatesMe(ctx context.Context, req *TLSyncUpdatesMe) (*mtproto.Void, error)

func (*UnimplementedRPCSyncServer) SyncUpdatesNotMe 

func (*UnimplementedRPCSyncServer) SyncUpdatesNotMe(ctx context.Context, req *TLSyncUpdatesNotMe) (*mtproto.Void, 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.