pb

package
v0.9.0 Latest Latest
Warning

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

Go to latest
Published: Nov 14, 2023 License: MIT Imports: 6 Imported by: 3

Documentation

Index

Constants

View Source
const MaxContentFilters = 10

MaxContentFilters is the maximum number of allowed content filters in a query

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_store_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ContentFilter

type ContentFilter struct {
	ContentTopic string `protobuf:"bytes,1,opt,name=content_topic,json=contentTopic,proto3" json:"content_topic,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 {

	// The first field is reserved for future use
	PubsubTopic    string           `protobuf:"bytes,2,opt,name=pubsub_topic,json=pubsubTopic,proto3" json:"pubsub_topic,omitempty"`
	ContentFilters []*ContentFilter `protobuf:"bytes,3,rep,name=content_filters,json=contentFilters,proto3" json:"content_filters,omitempty"`
	PagingInfo     *PagingInfo      `protobuf:"bytes,4,opt,name=paging_info,json=pagingInfo,proto3" json:"paging_info,omitempty"`
	StartTime      *int64           `protobuf:"zigzag64,5,opt,name=start_time,json=startTime,proto3,oneof" json:"start_time,omitempty"`
	EndTime        *int64           `protobuf:"zigzag64,6,opt,name=end_time,json=endTime,proto3,oneof" json:"end_time,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

func (*HistoryQuery) Validate added in v0.9.0

func (x *HistoryQuery) Validate() 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"`
	// 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

func (*HistoryRPC) ValidateQuery added in v0.9.0

func (x *HistoryRPC) ValidateQuery() error

func (*HistoryRPC) ValidateResponse added in v0.9.0

func (x *HistoryRPC) ValidateResponse(requestID string) error

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=paging_info,json=pagingInfo,proto3" json:"paging_info,omitempty"`
	Error      HistoryResponse_Error `protobuf:"varint,4,opt,name=error,proto3,enum=waku.store.v2beta4.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

func (*HistoryResponse) Validate added in v0.9.0

func (x *HistoryResponse) Validate() error

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) Enum

func (HistoryResponse_Error) EnumDescriptor deprecated

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

Deprecated: Use HistoryResponse_Error.Descriptor instead.

func (HistoryResponse_Error) Number

func (HistoryResponse_Error) String

func (x HistoryResponse_Error) String() string

func (HistoryResponse_Error) Type

type Index

type Index struct {
	Digest       []byte `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	ReceiverTime int64  `protobuf:"zigzag64,2,opt,name=receiver_time,json=receiverTime,proto3" json:"receiver_time,omitempty"`
	SenderTime   int64  `protobuf:"zigzag64,3,opt,name=sender_time,json=senderTime,proto3" json:"sender_time,omitempty"`
	PubsubTopic  string `protobuf:"bytes,4,opt,name=pubsub_topic,json=pubsubTopic,proto3" json:"pubsub_topic,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=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Cursor    *Index               `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Direction PagingInfo_Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=waku.store.v2beta4.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) Enum

func (PagingInfo_Direction) EnumDescriptor deprecated

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

Deprecated: Use PagingInfo_Direction.Descriptor instead.

func (PagingInfo_Direction) Number

func (PagingInfo_Direction) String

func (x PagingInfo_Direction) String() string

func (PagingInfo_Direction) Type

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL