pb

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2022 License: MIT Imports: 6 Imported by: 0

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 (
	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 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 added in v0.2.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RateLimitProof) Descriptor added in v0.2.0 

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

func (*RateLimitProof) GetEpoch added in v0.2.0 

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

func (*RateLimitProof) GetMerkleRoot added in v0.2.0 

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

func (*RateLimitProof) GetNullifier added in v0.2.0 

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

func (*RateLimitProof) GetProof added in v0.2.0 

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

func (*RateLimitProof) GetShareX added in v0.2.0 

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

func (*RateLimitProof) GetShareY added in v0.2.0 

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

func (*RateLimitProof) Marshal added in v0.2.0 

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

func (*RateLimitProof) MarshalTo added in v0.2.0 

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

func (*RateLimitProof) MarshalToSizedBuffer added in v0.2.0 

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

func (*RateLimitProof) ProtoMessage added in v0.2.0 

func (*RateLimitProof) ProtoMessage()

func (*RateLimitProof) Reset added in v0.2.0 

func (m *RateLimitProof) Reset()

func (*RateLimitProof) Size added in v0.2.0 

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

func (*RateLimitProof) String added in v0.2.0 

func (m *RateLimitProof) String() string

func (*RateLimitProof) Unmarshal added in v0.2.0 

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

func (*RateLimitProof) XXX_DiscardUnknown added in v0.2.0 

func (m *RateLimitProof) XXX_DiscardUnknown()

func (*RateLimitProof) XXX_Marshal added in v0.2.0 

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

func (*RateLimitProof) XXX_Merge added in v0.2.0 

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

func (*RateLimitProof) XXX_Size added in v0.2.0 

func (m *RateLimitProof) XXX_Size() int

func (*RateLimitProof) XXX_Unmarshal added in v0.2.0 

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 added in v0.2.2 

func (m *WakuMessage) GetEphemeral() bool

func (*WakuMessage) GetPayload 

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

func (*WakuMessage) GetRateLimitProof added in v0.2.0 

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, 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.