rpc

package

Go to main page

Versions in this module

v0

v0.2.2

Sep 15, 2022

v0.2.1

Aug 19, 2022

v0.2.1-lib-logging

Sep 7, 2022

v0.2.1-android-30

Sep 8, 2022

v0.2.0

Aug 18, 2022

Changes in this version

type DebugService

+ func NewDebugService(node *node.WakuNode) *DebugService

type RPCWakuMessage

+ RateLimitProof *RateLimitProof

type RPCWakuRelayMessage

+ RateLimitProof *RateLimitProof

+ type RateLimitProof struct

+ Epoch HexBytes

+ MerkleRoot HexBytes

+ Nullifier HexBytes

+ Proof HexBytes

+ ShareX HexBytes

+ ShareY HexBytes

v0.1.0

Jun 19, 2022

Changes in this version

+ type ByteArray []byte

+ func (h *ByteArray) UnmarshalText(b []byte) error

+ func (h ByteArray) MarshalText() ([]byte, error)

+ type CodecRequest struct

+ func (c *CodecRequest) Method() (string, error)

+ func (c *CodecRequest) ReadRequest(args interface{}) error

+ func (c *CodecRequest) WriteError(w http.ResponseWriter, _ int, err error)

+ func (c *CodecRequest) WriteResponse(w http.ResponseWriter, reply interface{})

+ type Error struct

+ Data interface{}

+ func (e *Error) Error() string

+ type HexBytes []byte

+ func (h *HexBytes) UnmarshalText(b []byte) error

+ func (u HexBytes) MarshalJSON() ([]byte, error)

type InfoReply

+ ENRUri string

+ ListenAddresses []string

type KeyPairReply

+ PublicKey string

type PrivateService

+ func (p *PrivateService) Start()

+ func (p *PrivateService) Stop()

+ type RPCWakuMessage struct

+ ContentTopic string

+ Payload ByteArray

+ Proof HexBytes

+ Timestamp int64

+ Version uint32

+ func ProtoWakuMessageToRPCWakuMessage(input *pb.WakuMessage) *RPCWakuMessage

+ type RPCWakuRelayMessage struct

+ ContentTopic string

+ Payload HexBytes

+ Proof HexBytes

+ Timestamp int64

+ Version uint32

+ func ProtoWakuMessageToRPCWakuRelayMessage(input *pb.WakuMessage) *RPCWakuRelayMessage

+ type RelayMessagesReply = []*RPCWakuRelayMessage

v0.0.1

May 26, 2022

Changes in this version

+ type Adder func(msg *protocol.Envelope)

+ type AdminService struct

+ func (a *AdminService) GetV1Peers(req *http.Request, args *GetPeersArgs, reply *PeersReply) error

+ func (a *AdminService) PostV1Peers(req *http.Request, args *PeersArgs, reply *SuccessReply) error

+ type AsymmetricMessageArgs struct

+ Message pb.WakuMessage

+ PublicKey string

+ Topic string

+ type AsymmetricMessagesArgs struct

+ PrivateKey string

+ Topic string

+ type ContentTopicArgs struct

+ ContentTopic string

+ type DebugService struct

+ func (d *DebugService) GetV1Info(r *http.Request, args *InfoArgs, reply *InfoReply) error

+ func (d *DebugService) GetV1Version(r *http.Request, args *InfoArgs, reply *VersionResponse) error

+ type Empty struct

+ type FilterContentArgs struct

+ ContentFilters []pb.ContentFilter

+ Topic string

+ type FilterService struct

+ func NewFilterService(node *node.WakuNode, log *zap.SugaredLogger) *FilterService

+ func (f *FilterService) DeleteV1Subscription(req *http.Request, args *FilterContentArgs, reply *SuccessReply) error

+ func (f *FilterService) GetV1Messages(req *http.Request, args *ContentTopicArgs, reply *MessagesReply) error

+ func (f *FilterService) PostV1Subscription(req *http.Request, args *FilterContentArgs, reply *SuccessReply) error

+ func (f *FilterService) Start()

+ func (f *FilterService) Stop()

+ type GetPeersArgs struct

+ type InfoArgs struct

+ type InfoReply struct

+ Version string

+ type KeyPairReply struct

+ PrivateKey string

+ PulicKey string

+ type MessagesReply struct

+ Messages []*pb.WakuMessage

+ type PeerReply struct

+ Connected bool

+ Multiaddr string

+ Protocol string

+ type PeersArgs struct

+ Peers []string

+ type PeersReply struct

+ Peers []PeerReply

+ type PrivateService struct

+ func NewPrivateService(node *node.WakuNode, log *zap.SugaredLogger) *PrivateService

+ func (p *PrivateService) GetV1AsymmetricKeypair(req *http.Request, args *Empty, reply *KeyPairReply) error

+ func (p *PrivateService) GetV1AsymmetricMessages(req *http.Request, args *AsymmetricMessagesArgs, reply *MessagesReply) error

+ func (p *PrivateService) GetV1SymmetricKey(req *http.Request, args *Empty, reply *SymmetricKeyReply) error

+ func (p *PrivateService) GetV1SymmetricMessages(req *http.Request, args *SymmetricMessagesArgs, reply *MessagesReply) error

+ func (p *PrivateService) PostV1AsymmetricMessage(req *http.Request, args *AsymmetricMessageArgs, reply *SuccessReply) error

+ func (p *PrivateService) PostV1SymmetricMessage(req *http.Request, args *SymmetricMessageArgs, reply *SuccessReply) error

+ type RelayMessageArgs struct

+ Message pb.WakuMessage

+ Topic string

+ type RelayService struct

+ func NewRelayService(node *node.WakuNode, log *zap.SugaredLogger) *RelayService

+ func (r *RelayService) DeleteV1Subscription(req *http.Request, args *TopicsArgs, reply *SuccessReply) error

+ func (r *RelayService) GetV1Messages(req *http.Request, args *TopicArgs, reply *MessagesReply) error

+ func (r *RelayService) PostV1Message(req *http.Request, args *RelayMessageArgs, reply *SuccessReply) error

+ func (r *RelayService) PostV1Subscription(req *http.Request, args *TopicsArgs, reply *SuccessReply) error

+ func (r *RelayService) Start()

+ func (r *RelayService) Stop()

+ type SnakeCaseCodec struct

+ func NewSnakeCaseCodec() *SnakeCaseCodec

+ func (c *SnakeCaseCodec) NewRequest(r *http.Request) rpc.CodecRequest

+ type SnakeCaseCodecRequest struct

+ func (c *SnakeCaseCodecRequest) Method() (string, error)

+ type StoreMessagesArgs struct

+ ContentFilters []string

+ EndTime int64

+ PagingOptions StorePagingOptions

+ StartTime int64

+ Topic string

+ type StoreMessagesReply struct

+ Error string

+ Messages []*pb.WakuMessage

+ PagingInfo StorePagingOptions

+ type StorePagingOptions struct

+ Cursor *pb.Index

+ Forward bool

+ PageSize uint64

+ type StoreService struct

+ func (s *StoreService) GetV1Messages(req *http.Request, args *StoreMessagesArgs, reply *StoreMessagesReply) error

+ type SuccessReply struct

+ Error string

+ Success bool

+ type SymmetricKeyReply struct

+ Key string

+ type SymmetricMessageArgs struct

+ Message pb.WakuMessage

+ SymKey string

+ Topic string

+ type SymmetricMessagesArgs struct

+ SymKey string

+ Topic string

+ type TopicArgs struct

+ Topic string

+ type TopicsArgs struct

+ Topics []string

+ type VersionResponse string

+ type WakuRpc struct

+ func NewWakuRpc(node *node.WakuNode, address string, port int, enableAdmin bool, ...) *WakuRpc

+ func (r *WakuRpc) Start()

+ func (r *WakuRpc) Stop(ctx context.Context) error

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