pb

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package pb holds only Protocol Buffer definitions and generated code.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMulticast        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMulticast          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMulticast = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type FindGroupReq 

type FindGroupReq struct {
	Gid   []byte   `protobuf:"bytes,1,opt,name=gid,proto3" json:"gid,omitempty"`
	Limit int32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Ttl   int32    `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Paths [][]byte `protobuf:"bytes,4,rep,name=paths,proto3" json:"paths,omitempty"`
}

func (*FindGroupReq) Descriptor 

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

func (*FindGroupReq) GetGid 

func (m *FindGroupReq) GetGid() []byte

func (*FindGroupReq) GetLimit 

func (m *FindGroupReq) GetLimit() int32

func (*FindGroupReq) GetPaths 

func (m *FindGroupReq) GetPaths() [][]byte

func (*FindGroupReq) GetTtl 

func (m *FindGroupReq) GetTtl() int32

func (*FindGroupReq) Marshal 

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

func (*FindGroupReq) MarshalTo 

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

func (*FindGroupReq) MarshalToSizedBuffer 

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

func (*FindGroupReq) ProtoMessage 

func (*FindGroupReq) ProtoMessage()

func (*FindGroupReq) Reset 

func (m *FindGroupReq) Reset()

func (*FindGroupReq) Size 

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

func (*FindGroupReq) String 

func (m *FindGroupReq) String() string

func (*FindGroupReq) Unmarshal 

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

func (*FindGroupReq) XXX_DiscardUnknown 

func (m *FindGroupReq) XXX_DiscardUnknown()

func (*FindGroupReq) XXX_Marshal 

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

func (*FindGroupReq) XXX_Merge 

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

func (*FindGroupReq) XXX_Size 

func (m *FindGroupReq) XXX_Size() int

func (*FindGroupReq) XXX_Unmarshal 

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

type FindGroupResp 

type FindGroupResp struct {
	Addresses [][]byte `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
}

func (*FindGroupResp) Descriptor 

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

func (*FindGroupResp) GetAddresses 

func (m *FindGroupResp) GetAddresses() [][]byte

func (*FindGroupResp) Marshal 

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

func (*FindGroupResp) MarshalTo 

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

func (*FindGroupResp) MarshalToSizedBuffer 

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

func (*FindGroupResp) ProtoMessage 

func (*FindGroupResp) ProtoMessage()

func (*FindGroupResp) Reset 

func (m *FindGroupResp) Reset()

func (*FindGroupResp) Size 

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

func (*FindGroupResp) String 

func (m *FindGroupResp) String() string

func (*FindGroupResp) Unmarshal 

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

func (*FindGroupResp) XXX_DiscardUnknown 

func (m *FindGroupResp) XXX_DiscardUnknown()

func (*FindGroupResp) XXX_Marshal 

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

func (*FindGroupResp) XXX_Merge 

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

func (*FindGroupResp) XXX_Size 

func (m *FindGroupResp) XXX_Size() int

func (*FindGroupResp) XXX_Unmarshal 

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

type GIDs 

type GIDs struct {
	Gid [][]byte `protobuf:"bytes,1,rep,name=gid,proto3" json:"gid,omitempty"`
}

func (*GIDs) Descriptor 

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

func (*GIDs) GetGid 

func (m *GIDs) GetGid() [][]byte

func (*GIDs) Marshal 

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

func (*GIDs) MarshalTo 

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

func (*GIDs) MarshalToSizedBuffer 

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

func (*GIDs) ProtoMessage 

func (*GIDs) ProtoMessage()

func (*GIDs) Reset 

func (m *GIDs) Reset()

func (*GIDs) Size 

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

func (*GIDs) String 

func (m *GIDs) String() string

func (*GIDs) Unmarshal 

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

func (*GIDs) XXX_DiscardUnknown 

func (m *GIDs) XXX_DiscardUnknown()

func (*GIDs) XXX_Marshal 

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

func (*GIDs) XXX_Merge 

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

func (*GIDs) XXX_Size 

func (m *GIDs) XXX_Size() int

func (*GIDs) XXX_Unmarshal 

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

type GroupMsg 

type GroupMsg struct {
	Gid  []byte `protobuf:"bytes,1,opt,name=gid,proto3" json:"gid,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Type int32  `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
	Err  string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
}

func (*GroupMsg) Descriptor 

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

func (*GroupMsg) GetData 

func (m *GroupMsg) GetData() []byte

func (*GroupMsg) GetErr 

func (m *GroupMsg) GetErr() string

func (*GroupMsg) GetGid 

func (m *GroupMsg) GetGid() []byte

func (*GroupMsg) GetType 

func (m *GroupMsg) GetType() int32

func (*GroupMsg) Marshal 

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

func (*GroupMsg) MarshalTo 

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

func (*GroupMsg) MarshalToSizedBuffer 

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

func (*GroupMsg) ProtoMessage 

func (*GroupMsg) ProtoMessage()

func (*GroupMsg) Reset 

func (m *GroupMsg) Reset()

func (*GroupMsg) Size 

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

func (*GroupMsg) String 

func (m *GroupMsg) String() string

func (*GroupMsg) Unmarshal 

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

func (*GroupMsg) XXX_DiscardUnknown 

func (m *GroupMsg) XXX_DiscardUnknown()

func (*GroupMsg) XXX_Marshal 

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

func (*GroupMsg) XXX_Merge 

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

func (*GroupMsg) XXX_Size 

func (m *GroupMsg) XXX_Size() int

func (*GroupMsg) XXX_Unmarshal 

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

type MulticastMsg 

type MulticastMsg struct {
	Id         uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	CreateTime int64  `protobuf:"varint,2,opt,name=createTime,proto3" json:"createTime,omitempty"`
	Origin     []byte `protobuf:"bytes,3,opt,name=origin,proto3" json:"origin,omitempty"`
	Gid        []byte `protobuf:"bytes,4,opt,name=gid,proto3" json:"gid,omitempty"`
	Data       []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
}

func (*MulticastMsg) Descriptor 

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

func (*MulticastMsg) GetCreateTime 

func (m *MulticastMsg) GetCreateTime() int64

func (*MulticastMsg) GetData 

func (m *MulticastMsg) GetData() []byte

func (*MulticastMsg) GetGid 

func (m *MulticastMsg) GetGid() []byte

func (*MulticastMsg) GetId 

func (m *MulticastMsg) GetId() uint64

func (*MulticastMsg) GetOrigin 

func (m *MulticastMsg) GetOrigin() []byte

func (*MulticastMsg) Marshal 

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

func (*MulticastMsg) MarshalTo 

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

func (*MulticastMsg) MarshalToSizedBuffer 

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

func (*MulticastMsg) ProtoMessage 

func (*MulticastMsg) ProtoMessage()

func (*MulticastMsg) Reset 

func (m *MulticastMsg) Reset()

func (*MulticastMsg) Size 

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

func (*MulticastMsg) String 

func (m *MulticastMsg) String() string

func (*MulticastMsg) Unmarshal 

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

func (*MulticastMsg) XXX_DiscardUnknown 

func (m *MulticastMsg) XXX_DiscardUnknown()

func (*MulticastMsg) XXX_Marshal 

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

func (*MulticastMsg) XXX_Merge 

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

func (*MulticastMsg) XXX_Size 

func (m *MulticastMsg) XXX_Size() int

func (*MulticastMsg) XXX_Unmarshal 

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

type Notify 

type Notify struct {
	Status int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Gids   [][]byte `protobuf:"bytes,2,rep,name=gids,proto3" json:"gids,omitempty"`
}

func (*Notify) Descriptor 

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

func (*Notify) GetGids 

func (m *Notify) GetGids() [][]byte

func (*Notify) GetStatus 

func (m *Notify) GetStatus() int32

func (*Notify) Marshal 

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

func (*Notify) MarshalTo 

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

func (*Notify) MarshalToSizedBuffer 

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

func (*Notify) ProtoMessage 

func (*Notify) ProtoMessage()

func (*Notify) Reset 

func (m *Notify) Reset()

func (*Notify) Size 

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

func (*Notify) String 

func (m *Notify) String() string

func (*Notify) Unmarshal 

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

func (*Notify) XXX_DiscardUnknown 

func (m *Notify) XXX_DiscardUnknown()

func (*Notify) XXX_Marshal 

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

func (*Notify) XXX_Merge 

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

func (*Notify) XXX_Size 

func (m *Notify) XXX_Size() int

func (*Notify) XXX_Unmarshal 

func (m *Notify) XXX_Unmarshal(b []byte) 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.