pb

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2022 License: MIT Imports: 6 Imported by: 12

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWakuFilter        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWakuFilter          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWakuFilter = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWakuLightpush        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWakuLightpush          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWakuLightpush = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWakuMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWakuMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWakuMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWakuPeerExchange        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWakuPeerExchange          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWakuPeerExchange = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWakuStore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWakuStore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWakuStore = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthWakuSwap        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWakuSwap          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWakuSwap = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var HistoryResponse_Error_name = map[int32]string{
	0: "NONE",
	1: "INVALID_CURSOR",
}
View Source 
var HistoryResponse_Error_value = map[string]int32{
	"NONE":           0,
	"INVALID_CURSOR": 1,
}
View Source 
var PagingInfo_Direction_name = map[int32]string{
	0: "BACKWARD",
	1: "FORWARD",
}
View Source 
var PagingInfo_Direction_value = map[string]int32{
	"BACKWARD": 0,
	"FORWARD":  1,
}

Functions

func Hash 

func Hash(data []byte) []byte

Hash calculates a hash from a byte slice using sha2-256 for the hashing algorithm

Types

type Cheque 

type Cheque struct {
	IssuerAddress        string   `protobuf:"bytes,1,opt,name=issuerAddress,proto3" json:"issuerAddress,omitempty"`
	Beneficiary          []byte   `protobuf:"bytes,2,opt,name=beneficiary,proto3" json:"beneficiary,omitempty"`
	Date                 uint32   `protobuf:"varint,3,opt,name=date,proto3" json:"date,omitempty"`
	Amount               uint32   `protobuf:"varint,4,opt,name=amount,proto3" json:"amount,omitempty"`
	Signature            []byte   `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Cheque) Descriptor 

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

func (*Cheque) GetAmount 

func (m *Cheque) GetAmount() uint32

func (*Cheque) GetBeneficiary 

func (m *Cheque) GetBeneficiary() []byte

func (*Cheque) GetDate 

func (m *Cheque) GetDate() uint32

func (*Cheque) GetIssuerAddress 

func (m *Cheque) GetIssuerAddress() string

func (*Cheque) GetSignature 

func (m *Cheque) GetSignature() []byte

func (*Cheque) Marshal 

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

func (*Cheque) MarshalTo 

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

func (*Cheque) MarshalToSizedBuffer 

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

func (*Cheque) ProtoMessage 

func (*Cheque) ProtoMessage()

func (*Cheque) Reset 

func (m *Cheque) Reset()

func (*Cheque) Size 

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

func (*Cheque) String 

func (m *Cheque) String() string

func (*Cheque) Unmarshal 

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

func (*Cheque) XXX_DiscardUnknown 

func (m *Cheque) XXX_DiscardUnknown()

func (*Cheque) XXX_Marshal 

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

func (*Cheque) XXX_Merge 

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

func (*Cheque) XXX_Size 

func (m *Cheque) XXX_Size() int

func (*Cheque) XXX_Unmarshal 

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

type ContentFilter 

type ContentFilter struct {
	ContentTopic         string   `protobuf:"bytes,1,opt,name=contentTopic,proto3" json:"contentTopic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContentFilter) Descriptor 

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

func (*ContentFilter) GetContentTopic 

func (m *ContentFilter) GetContentTopic() string

func (*ContentFilter) Marshal 

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

func (*ContentFilter) MarshalTo 

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

func (*ContentFilter) MarshalToSizedBuffer 

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

func (*ContentFilter) ProtoMessage 

func (*ContentFilter) ProtoMessage()

func (*ContentFilter) Reset 

func (m *ContentFilter) Reset()

func (*ContentFilter) Size 

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

func (*ContentFilter) String 

func (m *ContentFilter) String() string

func (*ContentFilter) Unmarshal 

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

func (*ContentFilter) XXX_DiscardUnknown 

func (m *ContentFilter) XXX_DiscardUnknown()

func (*ContentFilter) XXX_Marshal 

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

func (*ContentFilter) XXX_Merge 

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

func (*ContentFilter) XXX_Size 

func (m *ContentFilter) XXX_Size() int

func (*ContentFilter) XXX_Unmarshal 

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

type FilterRPC 

type FilterRPC struct {
	RequestId            string         `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"`
	Request              *FilterRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	Push                 *MessagePush   `protobuf:"bytes,3,opt,name=push,proto3" json:"push,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*FilterRPC) Descriptor 

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

func (*FilterRPC) GetPush 

func (m *FilterRPC) GetPush() *MessagePush

func (*FilterRPC) GetRequest 

func (m *FilterRPC) GetRequest() *FilterRequest

func (*FilterRPC) GetRequestId 

func (m *FilterRPC) GetRequestId() string

func (*FilterRPC) Marshal 

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

func (*FilterRPC) MarshalTo 

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

func (*FilterRPC) MarshalToSizedBuffer 

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

func (*FilterRPC) ProtoMessage 

func (*FilterRPC) ProtoMessage()

func (*FilterRPC) Reset 

func (m *FilterRPC) Reset()

func (*FilterRPC) Size 

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

func (*FilterRPC) String 

func (m *FilterRPC) String() string

func (*FilterRPC) Unmarshal 

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

func (*FilterRPC) XXX_DiscardUnknown 

func (m *FilterRPC) XXX_DiscardUnknown()

func (*FilterRPC) XXX_Marshal 

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

func (*FilterRPC) XXX_Merge 

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

func (*FilterRPC) XXX_Size 

func (m *FilterRPC) XXX_Size() int

func (*FilterRPC) XXX_Unmarshal 

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

type FilterRequest 

type FilterRequest struct {
	Subscribe            bool                           `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	Topic                string                         `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	ContentFilters       []*FilterRequest_ContentFilter `protobuf:"bytes,3,rep,name=contentFilters,proto3" json:"contentFilters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*FilterRequest) Descriptor 

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

func (*FilterRequest) GetContentFilters 

func (m *FilterRequest) GetContentFilters() []*FilterRequest_ContentFilter

func (*FilterRequest) GetSubscribe 

func (m *FilterRequest) GetSubscribe() bool

func (*FilterRequest) GetTopic 

func (m *FilterRequest) GetTopic() string

func (*FilterRequest) Marshal 

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

func (*FilterRequest) MarshalTo 

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

func (*FilterRequest) MarshalToSizedBuffer 

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

func (*FilterRequest) ProtoMessage 

func (*FilterRequest) ProtoMessage()

func (*FilterRequest) Reset 

func (m *FilterRequest) Reset()

func (*FilterRequest) Size 

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

func (*FilterRequest) String 

func (m *FilterRequest) String() string

func (*FilterRequest) Unmarshal 

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

func (*FilterRequest) XXX_DiscardUnknown 

func (m *FilterRequest) XXX_DiscardUnknown()

func (*FilterRequest) XXX_Marshal 

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

func (*FilterRequest) XXX_Merge 

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

func (*FilterRequest) XXX_Size 

func (m *FilterRequest) XXX_Size() int

func (*FilterRequest) XXX_Unmarshal 

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

type FilterRequest_ContentFilter 

type FilterRequest_ContentFilter struct {
	ContentTopic         string   `protobuf:"bytes,1,opt,name=contentTopic,proto3" json:"contentTopic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilterRequest_ContentFilter) Descriptor 

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

func (*FilterRequest_ContentFilter) GetContentTopic 

func (m *FilterRequest_ContentFilter) GetContentTopic() string

func (*FilterRequest_ContentFilter) Marshal 

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

func (*FilterRequest_ContentFilter) MarshalTo 

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

func (*FilterRequest_ContentFilter) MarshalToSizedBuffer 

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

func (*FilterRequest_ContentFilter) ProtoMessage 

func (*FilterRequest_ContentFilter) ProtoMessage()

func (*FilterRequest_ContentFilter) Reset 

func (m *FilterRequest_ContentFilter) Reset()

func (*FilterRequest_ContentFilter) Size 

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

func (*FilterRequest_ContentFilter) String 

func (m *FilterRequest_ContentFilter) String() string

func (*FilterRequest_ContentFilter) Unmarshal 

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

func (*FilterRequest_ContentFilter) XXX_DiscardUnknown 

func (m *FilterRequest_ContentFilter) XXX_DiscardUnknown()

func (*FilterRequest_ContentFilter) XXX_Marshal 

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

func (*FilterRequest_ContentFilter) XXX_Merge 

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

func (*FilterRequest_ContentFilter) XXX_Size 

func (m *FilterRequest_ContentFilter) XXX_Size() int

func (*FilterRequest_ContentFilter) XXX_Unmarshal 

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

type Handshake 

type Handshake struct {
	Beneficiary          []byte   `protobuf:"bytes,1,opt,name=beneficiary,proto3" json:"beneficiary,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Handshake) Descriptor 

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

func (*Handshake) GetBeneficiary 

func (m *Handshake) GetBeneficiary() []byte

func (*Handshake) Marshal 

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

func (*Handshake) MarshalTo 

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

func (*Handshake) MarshalToSizedBuffer 

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

func (*Handshake) ProtoMessage 

func (*Handshake) ProtoMessage()

func (*Handshake) Reset 

func (m *Handshake) Reset()

func (*Handshake) Size 

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

func (*Handshake) String 

func (m *Handshake) String() string

func (*Handshake) Unmarshal 

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

func (*Handshake) XXX_DiscardUnknown 

func (m *Handshake) XXX_DiscardUnknown()

func (*Handshake) XXX_Marshal 

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

func (*Handshake) XXX_Merge 

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

func (*Handshake) XXX_Size 

func (m *Handshake) XXX_Size() int

func (*Handshake) XXX_Unmarshal 

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

type HistoryQuery 

type HistoryQuery struct {
	PubsubTopic          string           `protobuf:"bytes,2,opt,name=pubsubTopic,proto3" json:"pubsubTopic,omitempty"`
	ContentFilters       []*ContentFilter `protobuf:"bytes,3,rep,name=contentFilters,proto3" json:"contentFilters,omitempty"`
	PagingInfo           *PagingInfo      `protobuf:"bytes,4,opt,name=pagingInfo,proto3" json:"pagingInfo,omitempty"`
	StartTime            int64            `protobuf:"zigzag64,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime              int64            `protobuf:"zigzag64,6,opt,name=endTime,proto3" json:"endTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*HistoryQuery) Descriptor 

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

func (*HistoryQuery) GetContentFilters 

func (m *HistoryQuery) GetContentFilters() []*ContentFilter

func (*HistoryQuery) GetEndTime 

func (m *HistoryQuery) GetEndTime() int64

func (*HistoryQuery) GetPagingInfo 

func (m *HistoryQuery) GetPagingInfo() *PagingInfo

func (*HistoryQuery) GetPubsubTopic 

func (m *HistoryQuery) GetPubsubTopic() string

func (*HistoryQuery) GetStartTime 

func (m *HistoryQuery) GetStartTime() int64

func (*HistoryQuery) Marshal 

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

func (*HistoryQuery) MarshalTo 

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

func (*HistoryQuery) MarshalToSizedBuffer 

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

func (*HistoryQuery) ProtoMessage 

func (*HistoryQuery) ProtoMessage()

func (*HistoryQuery) Reset 

func (m *HistoryQuery) Reset()

func (*HistoryQuery) Size 

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

func (*HistoryQuery) String 

func (m *HistoryQuery) String() string

func (*HistoryQuery) Unmarshal 

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

func (*HistoryQuery) XXX_DiscardUnknown 

func (m *HistoryQuery) XXX_DiscardUnknown()

func (*HistoryQuery) XXX_Marshal 

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

func (*HistoryQuery) XXX_Merge 

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

func (*HistoryQuery) XXX_Size 

func (m *HistoryQuery) XXX_Size() int

func (*HistoryQuery) XXX_Unmarshal 

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

type HistoryRPC 

type HistoryRPC struct {
	RequestId            string           `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Query                *HistoryQuery    `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Response             *HistoryResponse `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*HistoryRPC) Descriptor 

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

func (*HistoryRPC) GetQuery 

func (m *HistoryRPC) GetQuery() *HistoryQuery

func (*HistoryRPC) GetRequestId 

func (m *HistoryRPC) GetRequestId() string

func (*HistoryRPC) GetResponse 

func (m *HistoryRPC) GetResponse() *HistoryResponse

func (*HistoryRPC) Marshal 

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

func (*HistoryRPC) MarshalTo 

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

func (*HistoryRPC) MarshalToSizedBuffer 

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

func (*HistoryRPC) ProtoMessage 

func (*HistoryRPC) ProtoMessage()

func (*HistoryRPC) Reset 

func (m *HistoryRPC) Reset()

func (*HistoryRPC) Size 

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

func (*HistoryRPC) String 

func (m *HistoryRPC) String() string

func (*HistoryRPC) Unmarshal 

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

func (*HistoryRPC) XXX_DiscardUnknown 

func (m *HistoryRPC) XXX_DiscardUnknown()

func (*HistoryRPC) XXX_Marshal 

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

func (*HistoryRPC) XXX_Merge 

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

func (*HistoryRPC) XXX_Size 

func (m *HistoryRPC) XXX_Size() int

func (*HistoryRPC) XXX_Unmarshal 

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

type HistoryResponse 

type HistoryResponse struct {
	// the first field is reserved for future use
	Messages             []*WakuMessage        `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	PagingInfo           *PagingInfo           `protobuf:"bytes,3,opt,name=pagingInfo,proto3" json:"pagingInfo,omitempty"`
	Error                HistoryResponse_Error `protobuf:"varint,4,opt,name=error,proto3,enum=pb.HistoryResponse_Error" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*HistoryResponse) Descriptor 

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

func (*HistoryResponse) GetError 

func (m *HistoryResponse) GetError() HistoryResponse_Error

func (*HistoryResponse) GetMessages 

func (m *HistoryResponse) GetMessages() []*WakuMessage

func (*HistoryResponse) GetPagingInfo 

func (m *HistoryResponse) GetPagingInfo() *PagingInfo

func (*HistoryResponse) Marshal 

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

func (*HistoryResponse) MarshalTo 

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

func (*HistoryResponse) MarshalToSizedBuffer 

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

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) Reset 

func (m *HistoryResponse) Reset()

func (*HistoryResponse) Size 

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

func (*HistoryResponse) String 

func (m *HistoryResponse) String() string

func (*HistoryResponse) Unmarshal 

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

func (*HistoryResponse) XXX_DiscardUnknown 

func (m *HistoryResponse) XXX_DiscardUnknown()

func (*HistoryResponse) XXX_Marshal 

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

func (*HistoryResponse) XXX_Merge 

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

func (*HistoryResponse) XXX_Size 

func (m *HistoryResponse) XXX_Size() int

func (*HistoryResponse) XXX_Unmarshal 

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

type HistoryResponse_Error 

type HistoryResponse_Error int32
const (
	HistoryResponse_NONE           HistoryResponse_Error = 0
	HistoryResponse_INVALID_CURSOR HistoryResponse_Error = 1
)

func (HistoryResponse_Error) EnumDescriptor 

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

func (HistoryResponse_Error) String 

func (x HistoryResponse_Error) String() string

type Index 

type Index struct {
	Digest               []byte   `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	ReceiverTime         int64    `protobuf:"zigzag64,2,opt,name=receiverTime,proto3" json:"receiverTime,omitempty"`
	SenderTime           int64    `protobuf:"zigzag64,3,opt,name=senderTime,proto3" json:"senderTime,omitempty"`
	PubsubTopic          string   `protobuf:"bytes,4,opt,name=pubsubTopic,proto3" json:"pubsubTopic,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Index) Descriptor 

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

func (*Index) GetDigest 

func (m *Index) GetDigest() []byte

func (*Index) GetPubsubTopic 

func (m *Index) GetPubsubTopic() string

func (*Index) GetReceiverTime 

func (m *Index) GetReceiverTime() int64

func (*Index) GetSenderTime 

func (m *Index) GetSenderTime() int64

func (*Index) Marshal 

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

func (*Index) MarshalTo 

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

func (*Index) MarshalToSizedBuffer 

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

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) Reset 

func (m *Index) Reset()

func (*Index) Size 

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

func (*Index) String 

func (m *Index) String() string

func (*Index) Unmarshal 

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

func (*Index) XXX_DiscardUnknown 

func (m *Index) XXX_DiscardUnknown()

func (*Index) XXX_Marshal 

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

func (*Index) XXX_Merge 

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

func (*Index) XXX_Size 

func (m *Index) XXX_Size() int

func (*Index) XXX_Unmarshal 

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

type MessagePush 

type MessagePush struct {
	Messages             []*WakuMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MessagePush) Descriptor 

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

func (*MessagePush) GetMessages 

func (m *MessagePush) GetMessages() []*WakuMessage

func (*MessagePush) Marshal 

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

func (*MessagePush) MarshalTo 

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

func (*MessagePush) MarshalToSizedBuffer 

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

func (*MessagePush) ProtoMessage 

func (*MessagePush) ProtoMessage()

func (*MessagePush) Reset 

func (m *MessagePush) Reset()

func (*MessagePush) Size 

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

func (*MessagePush) String 

func (m *MessagePush) String() string

func (*MessagePush) Unmarshal 

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

func (*MessagePush) XXX_DiscardUnknown 

func (m *MessagePush) XXX_DiscardUnknown()

func (*MessagePush) XXX_Marshal 

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

func (*MessagePush) XXX_Merge 

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

func (*MessagePush) XXX_Size 

func (m *MessagePush) XXX_Size() int

func (*MessagePush) XXX_Unmarshal 

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

type PagingInfo 

type PagingInfo struct {
	PageSize             uint64               `protobuf:"varint,1,opt,name=pageSize,proto3" json:"pageSize,omitempty"`
	Cursor               *Index               `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Direction            PagingInfo_Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=pb.PagingInfo_Direction" json:"direction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PagingInfo) Descriptor 

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

func (*PagingInfo) GetCursor 

func (m *PagingInfo) GetCursor() *Index

func (*PagingInfo) GetDirection 

func (m *PagingInfo) GetDirection() PagingInfo_Direction

func (*PagingInfo) GetPageSize 

func (m *PagingInfo) GetPageSize() uint64

func (*PagingInfo) Marshal 

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

func (*PagingInfo) MarshalTo 

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

func (*PagingInfo) MarshalToSizedBuffer 

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

func (*PagingInfo) ProtoMessage 

func (*PagingInfo) ProtoMessage()

func (*PagingInfo) Reset 

func (m *PagingInfo) Reset()

func (*PagingInfo) Size 

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

func (*PagingInfo) String 

func (m *PagingInfo) String() string

func (*PagingInfo) Unmarshal 

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

func (*PagingInfo) XXX_DiscardUnknown 

func (m *PagingInfo) XXX_DiscardUnknown()

func (*PagingInfo) XXX_Marshal 

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

func (*PagingInfo) XXX_Merge 

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

func (*PagingInfo) XXX_Size 

func (m *PagingInfo) XXX_Size() int

func (*PagingInfo) XXX_Unmarshal 

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

type PagingInfo_Direction 

type PagingInfo_Direction int32
const (
	PagingInfo_BACKWARD PagingInfo_Direction = 0
	PagingInfo_FORWARD  PagingInfo_Direction = 1
)

func (PagingInfo_Direction) EnumDescriptor 

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

func (PagingInfo_Direction) String 

func (x PagingInfo_Direction) String() string

type PeerExchangeQuery 

type PeerExchangeQuery struct {
	NumPeers             uint64   `protobuf:"varint,1,opt,name=numPeers,proto3" json:"numPeers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerExchangeQuery) Descriptor 

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

func (*PeerExchangeQuery) GetNumPeers 

func (m *PeerExchangeQuery) GetNumPeers() uint64

func (*PeerExchangeQuery) Marshal 

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

func (*PeerExchangeQuery) MarshalTo 

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

func (*PeerExchangeQuery) MarshalToSizedBuffer 

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

func (*PeerExchangeQuery) ProtoMessage 

func (*PeerExchangeQuery) ProtoMessage()

func (*PeerExchangeQuery) Reset 

func (m *PeerExchangeQuery) Reset()

func (*PeerExchangeQuery) Size 

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

func (*PeerExchangeQuery) String 

func (m *PeerExchangeQuery) String() string

func (*PeerExchangeQuery) Unmarshal 

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

func (*PeerExchangeQuery) XXX_DiscardUnknown 

func (m *PeerExchangeQuery) XXX_DiscardUnknown()

func (*PeerExchangeQuery) XXX_Marshal 

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

func (*PeerExchangeQuery) XXX_Merge 

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

func (*PeerExchangeQuery) XXX_Size 

func (m *PeerExchangeQuery) XXX_Size() int

func (*PeerExchangeQuery) XXX_Unmarshal 

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

type PeerExchangeRPC 

type PeerExchangeRPC struct {
	Query                *PeerExchangeQuery    `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Response             *PeerExchangeResponse `protobuf:"bytes,2,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*PeerExchangeRPC) Descriptor 

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

func (*PeerExchangeRPC) GetQuery 

func (m *PeerExchangeRPC) GetQuery() *PeerExchangeQuery

func (*PeerExchangeRPC) GetResponse 

func (m *PeerExchangeRPC) GetResponse() *PeerExchangeResponse

func (*PeerExchangeRPC) Marshal 

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

func (*PeerExchangeRPC) MarshalTo 

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

func (*PeerExchangeRPC) MarshalToSizedBuffer 

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

func (*PeerExchangeRPC) ProtoMessage 

func (*PeerExchangeRPC) ProtoMessage()

func (*PeerExchangeRPC) Reset 

func (m *PeerExchangeRPC) Reset()

func (*PeerExchangeRPC) Size 

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

func (*PeerExchangeRPC) String 

func (m *PeerExchangeRPC) String() string

func (*PeerExchangeRPC) Unmarshal 

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

func (*PeerExchangeRPC) XXX_DiscardUnknown 

func (m *PeerExchangeRPC) XXX_DiscardUnknown()

func (*PeerExchangeRPC) XXX_Marshal 

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

func (*PeerExchangeRPC) XXX_Merge 

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

func (*PeerExchangeRPC) XXX_Size 

func (m *PeerExchangeRPC) XXX_Size() int

func (*PeerExchangeRPC) XXX_Unmarshal 

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

type PeerExchangeResponse 

type PeerExchangeResponse struct {
	PeerInfos            []*PeerInfo `protobuf:"bytes,1,rep,name=peerInfos,proto3" json:"peerInfos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*PeerExchangeResponse) Descriptor 

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

func (*PeerExchangeResponse) GetPeerInfos 

func (m *PeerExchangeResponse) GetPeerInfos() []*PeerInfo

func (*PeerExchangeResponse) Marshal 

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

func (*PeerExchangeResponse) MarshalTo 

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

func (*PeerExchangeResponse) MarshalToSizedBuffer 

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

func (*PeerExchangeResponse) ProtoMessage 

func (*PeerExchangeResponse) ProtoMessage()

func (*PeerExchangeResponse) Reset 

func (m *PeerExchangeResponse) Reset()

func (*PeerExchangeResponse) Size 

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

func (*PeerExchangeResponse) String 

func (m *PeerExchangeResponse) String() string

func (*PeerExchangeResponse) Unmarshal 

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

func (*PeerExchangeResponse) XXX_DiscardUnknown 

func (m *PeerExchangeResponse) XXX_DiscardUnknown()

func (*PeerExchangeResponse) XXX_Marshal 

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

func (*PeerExchangeResponse) XXX_Merge 

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

func (*PeerExchangeResponse) XXX_Size 

func (m *PeerExchangeResponse) XXX_Size() int

func (*PeerExchangeResponse) XXX_Unmarshal 

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

type PeerInfo 

type PeerInfo struct {
	ENR                  []byte   `protobuf:"bytes,1,opt,name=ENR,proto3" json:"ENR,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerInfo) Descriptor 

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

func (*PeerInfo) GetENR 

func (m *PeerInfo) GetENR() []byte

func (*PeerInfo) Marshal 

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

func (*PeerInfo) MarshalTo 

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

func (*PeerInfo) MarshalToSizedBuffer 

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

func (*PeerInfo) ProtoMessage 

func (*PeerInfo) ProtoMessage()

func (*PeerInfo) Reset 

func (m *PeerInfo) Reset()

func (*PeerInfo) Size 

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

func (*PeerInfo) String 

func (m *PeerInfo) String() string

func (*PeerInfo) Unmarshal 

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

func (*PeerInfo) XXX_DiscardUnknown 

func (m *PeerInfo) XXX_DiscardUnknown()

func (*PeerInfo) XXX_Marshal 

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

func (*PeerInfo) XXX_Merge 

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

func (*PeerInfo) XXX_Size 

func (m *PeerInfo) XXX_Size() int

func (*PeerInfo) XXX_Unmarshal 

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

type PushRPC 

type PushRPC struct {
	RequestId            string        `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Query                *PushRequest  `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	Response             *PushResponse `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*PushRPC) Descriptor 

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

func (*PushRPC) GetQuery 

func (m *PushRPC) GetQuery() *PushRequest

func (*PushRPC) GetRequestId 

func (m *PushRPC) GetRequestId() string

func (*PushRPC) GetResponse 

func (m *PushRPC) GetResponse() *PushResponse

func (*PushRPC) Marshal 

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

func (*PushRPC) MarshalTo 

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

func (*PushRPC) MarshalToSizedBuffer 

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

func (*PushRPC) ProtoMessage 

func (*PushRPC) ProtoMessage()

func (*PushRPC) Reset 

func (m *PushRPC) Reset()

func (*PushRPC) Size 

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

func (*PushRPC) String 

func (m *PushRPC) String() string

func (*PushRPC) Unmarshal 

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

func (*PushRPC) XXX_DiscardUnknown 

func (m *PushRPC) XXX_DiscardUnknown()

func (*PushRPC) XXX_Marshal 

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

func (*PushRPC) XXX_Merge 

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

func (*PushRPC) XXX_Size 

func (m *PushRPC) XXX_Size() int

func (*PushRPC) XXX_Unmarshal 

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

type PushRequest 

type PushRequest struct {
	PubsubTopic          string       `protobuf:"bytes,1,opt,name=pubsub_topic,json=pubsubTopic,proto3" json:"pubsub_topic,omitempty"`
	Message              *WakuMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PushRequest) Descriptor 

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

func (*PushRequest) GetMessage 

func (m *PushRequest) GetMessage() *WakuMessage

func (*PushRequest) GetPubsubTopic 

func (m *PushRequest) GetPubsubTopic() string

func (*PushRequest) Marshal 

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

func (*PushRequest) MarshalTo 

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

func (*PushRequest) MarshalToSizedBuffer 

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

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset 

func (m *PushRequest) Reset()

func (*PushRequest) Size 

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

func (*PushRequest) String 

func (m *PushRequest) String() string

func (*PushRequest) Unmarshal 

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

func (*PushRequest) XXX_DiscardUnknown 

func (m *PushRequest) XXX_DiscardUnknown()

func (*PushRequest) XXX_Marshal 

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

func (*PushRequest) XXX_Merge 

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

func (*PushRequest) XXX_Size 

func (m *PushRequest) XXX_Size() int

func (*PushRequest) XXX_Unmarshal 

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

type PushResponse 

type PushResponse struct {
	IsSuccess bool `protobuf:"varint,1,opt,name=is_success,json=isSuccess,proto3" json:"is_success,omitempty"`
	// Error messages, etc
	Info                 string   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushResponse) Descriptor 

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

func (*PushResponse) GetInfo 

func (m *PushResponse) GetInfo() string

func (*PushResponse) GetIsSuccess 

func (m *PushResponse) GetIsSuccess() bool

func (*PushResponse) Marshal 

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

func (*PushResponse) MarshalTo 

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

func (*PushResponse) MarshalToSizedBuffer 

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

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset 

func (m *PushResponse) Reset()

func (*PushResponse) Size 

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

func (*PushResponse) String 

func (m *PushResponse) String() string

func (*PushResponse) Unmarshal 

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

func (*PushResponse) XXX_DiscardUnknown 

func (m *PushResponse) XXX_DiscardUnknown()

func (*PushResponse) XXX_Marshal 

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

func (*PushResponse) XXX_Merge 

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

func (*PushResponse) XXX_Size 

func (m *PushResponse) XXX_Size() int

func (*PushResponse) XXX_Unmarshal 

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

type RateLimitProof 

type RateLimitProof struct {
	Proof                []byte   `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
	MerkleRoot           []byte   `protobuf:"bytes,2,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"`
	Epoch                []byte   `protobuf:"bytes,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	ShareX               []byte   `protobuf:"bytes,4,opt,name=share_x,json=shareX,proto3" json:"share_x,omitempty"`
	ShareY               []byte   `protobuf:"bytes,5,opt,name=share_y,json=shareY,proto3" json:"share_y,omitempty"`
	Nullifier            []byte   `protobuf:"bytes,6,opt,name=nullifier,proto3" json:"nullifier,omitempty"`
	RlnIdentifier        []byte   `protobuf:"bytes,7,opt,name=rln_identifier,json=rlnIdentifier,proto3" json:"rln_identifier,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RateLimitProof) Descriptor 

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

func (*RateLimitProof) GetEpoch 

func (m *RateLimitProof) GetEpoch() []byte

func (*RateLimitProof) GetMerkleRoot 

func (m *RateLimitProof) GetMerkleRoot() []byte

func (*RateLimitProof) GetNullifier 

func (m *RateLimitProof) GetNullifier() []byte

func (*RateLimitProof) GetProof 

func (m *RateLimitProof) GetProof() []byte

func (*RateLimitProof) GetRlnIdentifier 

func (m *RateLimitProof) GetRlnIdentifier() []byte

func (*RateLimitProof) GetShareX 

func (m *RateLimitProof) GetShareX() []byte

func (*RateLimitProof) GetShareY 

func (m *RateLimitProof) GetShareY() []byte

func (*RateLimitProof) Marshal 

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

func (*RateLimitProof) MarshalTo 

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

func (*RateLimitProof) MarshalToSizedBuffer 

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

func (*RateLimitProof) ProtoMessage 

func (*RateLimitProof) ProtoMessage()

func (*RateLimitProof) Reset 

func (m *RateLimitProof) Reset()

func (*RateLimitProof) Size 

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

func (*RateLimitProof) String 

func (m *RateLimitProof) String() string

func (*RateLimitProof) Unmarshal 

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

func (*RateLimitProof) XXX_DiscardUnknown 

func (m *RateLimitProof) XXX_DiscardUnknown()

func (*RateLimitProof) XXX_Marshal 

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

func (*RateLimitProof) XXX_Merge 

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

func (*RateLimitProof) XXX_Size 

func (m *RateLimitProof) XXX_Size() int

func (*RateLimitProof) XXX_Unmarshal 

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

type WakuMessage 

type WakuMessage struct {
	Payload              []byte          `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	ContentTopic         string          `protobuf:"bytes,2,opt,name=contentTopic,proto3" json:"contentTopic,omitempty"`
	Version              uint32          `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	Timestamp            int64           `protobuf:"zigzag64,10,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	RateLimitProof       *RateLimitProof `protobuf:"bytes,21,opt,name=rate_limit_proof,json=rateLimitProof,proto3" json:"rate_limit_proof,omitempty"`
	Ephemeral            bool            `protobuf:"varint,31,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*WakuMessage) Descriptor 

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

func (*WakuMessage) GetContentTopic 

func (m *WakuMessage) GetContentTopic() string

func (*WakuMessage) GetEphemeral 

func (m *WakuMessage) GetEphemeral() bool

func (*WakuMessage) GetPayload 

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

func (*WakuMessage) GetRateLimitProof 

func (m *WakuMessage) GetRateLimitProof() *RateLimitProof

func (*WakuMessage) GetTimestamp 

func (m *WakuMessage) GetTimestamp() int64

func (*WakuMessage) GetVersion 

func (m *WakuMessage) GetVersion() uint32

func (*WakuMessage) Hash 

func (msg *WakuMessage) Hash() ([]byte, int, error)

Hash calculates the hash of a waku message

func (*WakuMessage) Marshal 

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

func (*WakuMessage) MarshalTo 

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

func (*WakuMessage) MarshalToSizedBuffer 

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

func (*WakuMessage) ProtoMessage 

func (*WakuMessage) ProtoMessage()

func (*WakuMessage) Reset 

func (m *WakuMessage) Reset()

func (*WakuMessage) Size 

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

func (*WakuMessage) String 

func (m *WakuMessage) String() string

func (*WakuMessage) Unmarshal 

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

func (*WakuMessage) XXX_DiscardUnknown 

func (m *WakuMessage) XXX_DiscardUnknown()

func (*WakuMessage) XXX_Marshal 

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

func (*WakuMessage) XXX_Merge 

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

func (*WakuMessage) XXX_Size 

func (m *WakuMessage) XXX_Size() int

func (*WakuMessage) XXX_Unmarshal 

func (m *WakuMessage) 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.