rpc

type Adder func(msg *protocol.Envelope)

type AdminService struct {
	// contains filtered or unexported fields
}

type Base64URLByte []byte

type CodecRequest struct {
	// contains filtered or unexported fields
}

type ContentTopicArgs struct {
	ContentTopic string `json:"contentTopic,omitempty"`
}

type DebugService struct {
	// contains filtered or unexported fields
}

type Empty struct {
}

type Error struct {
	Data interface{}
}

type FilterContentArgs struct {
	Topic          string                            `json:"topic,omitempty"`
	ContentFilters []*pb.FilterRequest_ContentFilter `json:"contentFilters,omitempty"`
}

type FilterService struct {
	// contains filtered or unexported fields
}

type GetPeersArgs struct {
}

type InfoArgs struct {
}

type InfoReply struct {
	ENRUri          string   `json:"enrUri,omitempty"`
	ListenAddresses []string `json:"listenAddresses,omitempty"`
}

type MessagesReply = []*RPCWakuMessage

type PeerReply struct {
	Multiaddr string      `json:"multiaddr,omitempty"`
	Protocol  protocol.ID `json:"protocol,omitempty"`
	Connected bool        `json:"connected,omitempty"`
}

type PeersArgs struct {
	Peers []string `json:"peers,omitempty"`
}

type PeersReply []PeerReply

type RPCWakuMessage struct {
	Payload        server.Base64URLByte `json:"payload,omitempty"`
	ContentTopic   string               `json:"contentTopic,omitempty"`
	Version        uint32               `json:"version"`
	Timestamp      int64                `json:"timestamp,omitempty"`
	RateLimitProof *RateLimitProof      `json:"rateLimitProof,omitempty"`
	Ephemeral      bool                 `json:"ephemeral,omitempty"`
}

type RateLimitProof struct {
	Proof         Base64URLByte `json:"proof,omitempty"`
	MerkleRoot    Base64URLByte `json:"merkle_root,omitempty"`
	Epoch         Base64URLByte `json:"epoch,omitempty"`
	ShareX        Base64URLByte `json:"share_x,omitempty"`
	ShareY        Base64URLByte `json:"share_y,omitempty"`
	Nullifier     Base64URLByte `json:"nullifier,omitempty"`
	RlnIdentifier Base64URLByte `json:"rln_identifier,omitempty"`
}

type RelayAutoMessageArgs struct {
	Message *RPCWakuMessage `json:"message,omitempty"`
}

type RelayMessageArgs struct {
	Topic   string          `json:"topic,omitempty"`
	Message *RPCWakuMessage `json:"message,omitempty"`
}

type RelayService struct {
	// contains filtered or unexported fields
}

type SnakeCaseCodec struct {
}

type StoreMessagesArgs struct {
	Topic          string             `json:"pubsubTopic,omitempty"`
	ContentFilters []string           `json:"contentFilters,omitempty"`
	StartTime      *int64             `json:"startTime,omitempty"`
	EndTime        *int64             `json:"endTime,omitempty"`
	PagingOptions  StorePagingOptions `json:"pagingOptions,omitempty"`
}

type StoreMessagesReply struct {
	Messages   []*RPCWakuMessage  `json:"messages,omitempty"`
	PagingInfo StorePagingOptions `json:"pagingInfo,omitempty"`
	Error      string             `json:"error,omitempty"`
}

type StorePagingOptions struct {
	PageSize uint64    `json:"pageSize,omitempty"`
	Cursor   *pb.Index `json:"cursor,omitempty"`
	Forward  bool      `json:"forward,omitempty"`
}

type StoreService struct {
	// contains filtered or unexported fields
}

type SuccessReply = bool

type TopicArgs struct {
	Topic string `json:"topic,omitempty"`
}

type TopicsArgs struct {
	Topics []string `json:"topics,omitempty"`
}

type VersionResponse string

type WakuRPC struct {
	// contains filtered or unexported fields
}