pb

package
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2023 License: MIT Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	PagingInfo_Direction_name = map[int32]string{
		0: "BACKWARD",
		1: "FORWARD",
	}
	PagingInfo_Direction_value = map[string]int32{
		"BACKWARD": 0,
		"FORWARD":  1,
	}
)

Enum value maps for PagingInfo_Direction.

View Source 
var (
	HistoryResponse_Error_name = map[int32]string{
		0: "NONE",
		1: "INVALID_CURSOR",
	}
	HistoryResponse_Error_value = map[string]int32{
		"NONE":           0,
		"INVALID_CURSOR": 1,
	}
)

Enum value maps for HistoryResponse_Error.

View Source 
var File_waku_store_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ContentFilter 

type ContentFilter struct {
	ContentTopic string `protobuf:"bytes,1,opt,name=contentTopic,proto3" json:"contentTopic,omitempty"`
	// contains filtered or unexported fields
}

func (*ContentFilter) Descriptor deprecated 

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

Deprecated: Use ContentFilter.ProtoReflect.Descriptor instead.

func (*ContentFilter) GetContentTopic 

func (x *ContentFilter) GetContentTopic() string

func (*ContentFilter) ProtoMessage 

func (*ContentFilter) ProtoMessage()

func (*ContentFilter) ProtoReflect 

func (x *ContentFilter) ProtoReflect() protoreflect.Message

func (*ContentFilter) Reset 

func (x *ContentFilter) Reset()

func (*ContentFilter) String 

func (x *ContentFilter) String() string

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"` // used for pagination
	StartTime      int64            `protobuf:"zigzag64,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime        int64            `protobuf:"zigzag64,6,opt,name=endTime,proto3" json:"endTime,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryQuery) Descriptor deprecated 

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

Deprecated: Use HistoryQuery.ProtoReflect.Descriptor instead.

func (*HistoryQuery) GetContentFilters 

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

func (*HistoryQuery) GetEndTime 

func (x *HistoryQuery) GetEndTime() int64

func (*HistoryQuery) GetPagingInfo 

func (x *HistoryQuery) GetPagingInfo() *PagingInfo

func (*HistoryQuery) GetPubsubTopic 

func (x *HistoryQuery) GetPubsubTopic() string

func (*HistoryQuery) GetStartTime 

func (x *HistoryQuery) GetStartTime() int64

func (*HistoryQuery) ProtoMessage 

func (*HistoryQuery) ProtoMessage()

func (*HistoryQuery) ProtoReflect 

func (x *HistoryQuery) ProtoReflect() protoreflect.Message

func (*HistoryQuery) Reset 

func (x *HistoryQuery) Reset()

func (*HistoryQuery) String 

func (x *HistoryQuery) String() string

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"`
	// contains filtered or unexported fields
}

func (*HistoryRPC) Descriptor deprecated 

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

Deprecated: Use HistoryRPC.ProtoReflect.Descriptor instead.

func (*HistoryRPC) GetQuery 

func (x *HistoryRPC) GetQuery() *HistoryQuery

func (*HistoryRPC) GetRequestId 

func (x *HistoryRPC) GetRequestId() string

func (*HistoryRPC) GetResponse 

func (x *HistoryRPC) GetResponse() *HistoryResponse

func (*HistoryRPC) ProtoMessage 

func (*HistoryRPC) ProtoMessage()

func (*HistoryRPC) ProtoReflect 

func (x *HistoryRPC) ProtoReflect() protoreflect.Message

func (*HistoryRPC) Reset 

func (x *HistoryRPC) Reset()

func (*HistoryRPC) String 

func (x *HistoryRPC) String() string

type HistoryResponse 

type HistoryResponse struct {

	// the first field is reserved for future use
	Messages   []*pb.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"`
	// contains filtered or unexported fields
}

func (*HistoryResponse) Descriptor deprecated 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetError 

func (x *HistoryResponse) GetError() HistoryResponse_Error

func (*HistoryResponse) GetMessages 

func (x *HistoryResponse) GetMessages() []*pb.WakuMessage

func (*HistoryResponse) GetPagingInfo 

func (x *HistoryResponse) GetPagingInfo() *PagingInfo

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect 

func (x *HistoryResponse) ProtoReflect() protoreflect.Message

func (*HistoryResponse) Reset 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String 

func (x *HistoryResponse) String() string

type HistoryResponse_Error 

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

func (HistoryResponse_Error) Descriptor 

func (HistoryResponse_Error) Descriptor() protoreflect.EnumDescriptor

func (HistoryResponse_Error) Enum 

func (x HistoryResponse_Error) Enum() *HistoryResponse_Error

func (HistoryResponse_Error) EnumDescriptor deprecated 

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

Deprecated: Use HistoryResponse_Error.Descriptor instead.

func (HistoryResponse_Error) Number 

func (x HistoryResponse_Error) Number() protoreflect.EnumNumber

func (HistoryResponse_Error) String 

func (x HistoryResponse_Error) String() string

func (HistoryResponse_Error) Type 

func (HistoryResponse_Error) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*Index) Descriptor deprecated 

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

Deprecated: Use Index.ProtoReflect.Descriptor instead.

func (*Index) GetDigest 

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

func (*Index) GetPubsubTopic 

func (x *Index) GetPubsubTopic() string

func (*Index) GetReceiverTime 

func (x *Index) GetReceiverTime() int64

func (*Index) GetSenderTime 

func (x *Index) GetSenderTime() int64

func (*Index) ProtoMessage 

func (*Index) ProtoMessage()

func (*Index) ProtoReflect 

func (x *Index) ProtoReflect() protoreflect.Message

func (*Index) Reset 

func (x *Index) Reset()

func (*Index) String 

func (x *Index) String() string

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"`
	// contains filtered or unexported fields
}

func (*PagingInfo) Descriptor deprecated 

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

Deprecated: Use PagingInfo.ProtoReflect.Descriptor instead.

func (*PagingInfo) GetCursor 

func (x *PagingInfo) GetCursor() *Index

func (*PagingInfo) GetDirection 

func (x *PagingInfo) GetDirection() PagingInfo_Direction

func (*PagingInfo) GetPageSize 

func (x *PagingInfo) GetPageSize() uint64

func (*PagingInfo) ProtoMessage 

func (*PagingInfo) ProtoMessage()

func (*PagingInfo) ProtoReflect 

func (x *PagingInfo) ProtoReflect() protoreflect.Message

func (*PagingInfo) Reset 

func (x *PagingInfo) Reset()

func (*PagingInfo) String 

func (x *PagingInfo) String() string

type PagingInfo_Direction 

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

func (PagingInfo_Direction) Descriptor 

func (PagingInfo_Direction) Descriptor() protoreflect.EnumDescriptor

func (PagingInfo_Direction) Enum 

func (x PagingInfo_Direction) Enum() *PagingInfo_Direction

func (PagingInfo_Direction) EnumDescriptor deprecated 

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

Deprecated: Use PagingInfo_Direction.Descriptor instead.

func (PagingInfo_Direction) Number 

func (x PagingInfo_Direction) Number() protoreflect.EnumNumber

func (PagingInfo_Direction) String 

func (x PagingInfo_Direction) String() string

func (PagingInfo_Direction) Type 

func (PagingInfo_Direction) Type() protoreflect.EnumType

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.