wakuext

Documentation

Index

• type PublicAPI
  • func NewPublicAPI(s *Service) *PublicAPI
  • func (api *PublicAPI) RequestMessages(_ context.Context, r ext.MessagesRequest) (types.HexBytes, error)
  • func (api *PublicAPI) RequestMessagesSync(conf ext.RetryConfig, r ext.MessagesRequest) (ext.MessagesResponse, error)
• type Service
  • func New(config params.ShhextConfig, n types.Node, ctx interface{}, ...) *Service
  • func (s *Service) APIs() []rpc.API
  • func (s *Service) PublicWakuAPI() types.PublicWakuAPI

Types

type PublicAPI

type PublicAPI struct {
	*ext.PublicAPI
	// contains filtered or unexported fields
}

PublicAPI extends waku public API.

func NewPublicAPI

func NewPublicAPI(s *Service) *PublicAPI

NewPublicAPI returns instance of the public API.

func (*PublicAPI) RequestMessages

func (api *PublicAPI) RequestMessages(_ context.Context, r ext.MessagesRequest) (types.HexBytes, error)

RequestMessages sends a request for historic messages to a MailServer.

func (*PublicAPI) RequestMessagesSync

func (api *PublicAPI) RequestMessagesSync(conf ext.RetryConfig, r ext.MessagesRequest) (ext.MessagesResponse, error)

RequestMessagesSync repeats MessagesRequest using configuration in retry conf.

type Service

type Service struct {
	*ext.Service
	// contains filtered or unexported fields
}

func New

func New(config params.ShhextConfig, n types.Node, ctx interface{}, handler ext.EnvelopeEventsHandler, ldb *leveldb.DB) *Service

func (*Service) APIs

func (s *Service) APIs() []rpc.API

APIs returns a list of new APIs.

func (*Service) PublicWakuAPI

func (s *Service) PublicWakuAPI() types.PublicWakuAPI