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: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const MaxContentTopicsPerRequest = 30

Variables

View Source 
var (
	FilterSubscribeRequest_FilterSubscribeType_name = map[int32]string{
		0: "SUBSCRIBER_PING",
		1: "SUBSCRIBE",
		2: "UNSUBSCRIBE",
		3: "UNSUBSCRIBE_ALL",
	}
	FilterSubscribeRequest_FilterSubscribeType_value = map[string]int32{
		"SUBSCRIBER_PING": 0,
		"SUBSCRIBE":       1,
		"UNSUBSCRIBE":     2,
		"UNSUBSCRIBE_ALL": 3,
	}
)

Enum value maps for FilterSubscribeRequest_FilterSubscribeType.

View Source 
var File_filter_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type FilterSubscribeRequest added in v0.6.0 

type FilterSubscribeRequest struct {
	RequestId           string                                     `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	FilterSubscribeType FilterSubscribeRequest_FilterSubscribeType `` /* 184-byte string literal not displayed */
	// Filter criteria
	PubsubTopic   *string  `protobuf:"bytes,10,opt,name=pubsub_topic,json=pubsubTopic,proto3,oneof" json:"pubsub_topic,omitempty"`
	ContentTopics []string `protobuf:"bytes,11,rep,name=content_topics,json=contentTopics,proto3" json:"content_topics,omitempty"`
	// contains filtered or unexported fields
}

Protocol identifier: /vac/waku/filter-subscribe/2.0.0-beta1

func (*FilterSubscribeRequest) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use FilterSubscribeRequest.ProtoReflect.Descriptor instead.

func (*FilterSubscribeRequest) GetContentTopics added in v0.6.0 

func (x *FilterSubscribeRequest) GetContentTopics() []string

func (*FilterSubscribeRequest) GetFilterSubscribeType added in v0.6.0 

func (x *FilterSubscribeRequest) GetFilterSubscribeType() FilterSubscribeRequest_FilterSubscribeType

func (*FilterSubscribeRequest) GetPubsubTopic added in v0.6.0 

func (x *FilterSubscribeRequest) GetPubsubTopic() string

func (*FilterSubscribeRequest) GetRequestId added in v0.6.0 

func (x *FilterSubscribeRequest) GetRequestId() string

func (*FilterSubscribeRequest) ProtoMessage added in v0.6.0 

func (*FilterSubscribeRequest) ProtoMessage()

func (*FilterSubscribeRequest) ProtoReflect added in v0.6.0 

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

func (*FilterSubscribeRequest) Reset added in v0.6.0 

func (x *FilterSubscribeRequest) Reset()

func (*FilterSubscribeRequest) String added in v0.6.0 

func (x *FilterSubscribeRequest) String() string

func (*FilterSubscribeRequest) Validate added in v0.9.0 

func (x *FilterSubscribeRequest) Validate() error

type FilterSubscribeRequest_FilterSubscribeType added in v0.6.0 

type FilterSubscribeRequest_FilterSubscribeType int32
const (
	FilterSubscribeRequest_SUBSCRIBER_PING FilterSubscribeRequest_FilterSubscribeType = 0
	FilterSubscribeRequest_SUBSCRIBE       FilterSubscribeRequest_FilterSubscribeType = 1
	FilterSubscribeRequest_UNSUBSCRIBE     FilterSubscribeRequest_FilterSubscribeType = 2
	FilterSubscribeRequest_UNSUBSCRIBE_ALL FilterSubscribeRequest_FilterSubscribeType = 3
)

func (FilterSubscribeRequest_FilterSubscribeType) Descriptor added in v0.6.0 

func (FilterSubscribeRequest_FilterSubscribeType) Descriptor() protoreflect.EnumDescriptor

func (FilterSubscribeRequest_FilterSubscribeType) Enum added in v0.6.0 

func (x FilterSubscribeRequest_FilterSubscribeType) Enum() *FilterSubscribeRequest_FilterSubscribeType

func (FilterSubscribeRequest_FilterSubscribeType) EnumDescriptor deprecated added in v0.6.0 

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

Deprecated: Use FilterSubscribeRequest_FilterSubscribeType.Descriptor instead.

func (FilterSubscribeRequest_FilterSubscribeType) Number added in v0.6.0 

func (x FilterSubscribeRequest_FilterSubscribeType) Number() protoreflect.EnumNumber

func (FilterSubscribeRequest_FilterSubscribeType) String added in v0.6.0 

func (x FilterSubscribeRequest_FilterSubscribeType) String() string

func (FilterSubscribeRequest_FilterSubscribeType) Type added in v0.6.0 

func (FilterSubscribeRequest_FilterSubscribeType) Type() protoreflect.EnumType

type FilterSubscribeResponse added in v0.6.0 

type FilterSubscribeResponse struct {
	RequestId  string  `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	StatusCode uint32  `protobuf:"varint,10,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	StatusDesc *string `protobuf:"bytes,11,opt,name=status_desc,json=statusDesc,proto3,oneof" json:"status_desc,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterSubscribeResponse) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use FilterSubscribeResponse.ProtoReflect.Descriptor instead.

func (*FilterSubscribeResponse) GetRequestId added in v0.6.0 

func (x *FilterSubscribeResponse) GetRequestId() string

func (*FilterSubscribeResponse) GetStatusCode added in v0.6.0 

func (x *FilterSubscribeResponse) GetStatusCode() uint32

func (*FilterSubscribeResponse) GetStatusDesc added in v0.6.0 

func (x *FilterSubscribeResponse) GetStatusDesc() string

func (*FilterSubscribeResponse) ProtoMessage added in v0.6.0 

func (*FilterSubscribeResponse) ProtoMessage()

func (*FilterSubscribeResponse) ProtoReflect added in v0.6.0 

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

func (*FilterSubscribeResponse) Reset added in v0.6.0 

func (x *FilterSubscribeResponse) Reset()

func (*FilterSubscribeResponse) String added in v0.6.0 

func (x *FilterSubscribeResponse) String() string

func (*FilterSubscribeResponse) Validate added in v0.9.0 

func (x *FilterSubscribeResponse) Validate() error

type MessagePush 

type MessagePush struct {
	WakuMessage *pb.WakuMessage `protobuf:"bytes,1,opt,name=waku_message,json=wakuMessage,proto3" json:"waku_message,omitempty"`
	PubsubTopic *string         `protobuf:"bytes,2,opt,name=pubsub_topic,json=pubsubTopic,proto3,oneof" json:"pubsub_topic,omitempty"`
	// contains filtered or unexported fields
}

Protocol identifier: /vac/waku/filter-push/2.0.0-beta1

func (*MessagePush) Descriptor deprecated 

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

Deprecated: Use MessagePush.ProtoReflect.Descriptor instead.

func (*MessagePush) GetPubsubTopic added in v0.9.0 

func (x *MessagePush) GetPubsubTopic() string

func (*MessagePush) GetWakuMessage added in v0.9.0 

func (x *MessagePush) GetWakuMessage() *pb.WakuMessage

func (*MessagePush) ProtoMessage 

func (*MessagePush) ProtoMessage()

func (*MessagePush) ProtoReflect 

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

func (*MessagePush) Reset 

func (x *MessagePush) Reset()

func (*MessagePush) String 

func (x *MessagePush) String() string

func (*MessagePush) Validate added in v0.9.0 

func (x *MessagePush) Validate() 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.