rest

Documentation

Index

• Constants
• type Adder
• type DebugService
  • func NewDebugService(node *node.WakuNode, m *mux.Router) *DebugService
• type InfoArgs
• type InfoReply
• type RelayService
  • func NewRelayService(node *node.WakuNode, m *mux.Router, cacheCapacity int, log *zap.Logger) *RelayService
  • func (r *RelayService) Start(ctx context.Context)
  • func (r *RelayService) Stop()
• type VersionResponse
• type WakuRest
  • func NewWakuRest(node *node.WakuNode, address string, port int, enableAdmin bool, ...) *WakuRest
  • func (r *WakuRest) Start(ctx context.Context, wg *sync.WaitGroup)
  • func (r *WakuRest) Stop(ctx context.Context) error

Constants

const ROUTE_DEBUG_INFOV1 = "/debug/v1/info"

const ROUTE_DEBUG_VERSIONV1 = "/debug/v1/info"

const ROUTE_RELAY_MESSAGESV1 = "/relay/v1/messages/{topic}"

const ROUTE_RELAY_SUBSCRIPTIONSV1 = "/relay/v1/subscriptions"

Types

type Adder

type Adder func(msg *protocol.Envelope)

type DebugService

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

func NewDebugService

func NewDebugService(node *node.WakuNode, m *mux.Router) *DebugService

type InfoArgs

type InfoArgs struct {
}

type InfoReply

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

type RelayService

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

func NewRelayService

func NewRelayService(node *node.WakuNode, m *mux.Router, cacheCapacity int, log *zap.Logger) *RelayService

func (*RelayService) Start

func (r *RelayService) Start(ctx context.Context)

func (*RelayService) Stop

func (r *RelayService) Stop()

type VersionResponse

type VersionResponse string

type WakuRest

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

func NewWakuRest

func NewWakuRest(node *node.WakuNode, address string, port int, enableAdmin bool, enablePrivate bool, enablePProf bool, relayCacheCapacity int, log *zap.Logger) *WakuRest

func (*WakuRest) Start

func (r *WakuRest) Start(ctx context.Context, wg *sync.WaitGroup)

func (*WakuRest) Stop

func (r *WakuRest) Stop(ctx context.Context) error