pubsub

Documentation

Index

• Variables
• type Service
  • func New(srv nodeIface.Service) (*Service, error)
  • func (s *Service) Cache() iface.Cache
  • func (s *Service) CheckTns(_matcher commonIface.MatchDefinition) ([]commonIface.Serviceable, error)
  • func (s *Service) Close() error
  • func (s *Service) Context() context.Context
  • func (s *Service) GetMessagingsMap(matcher *common.MatchDefinition) (messagingsMap *common.MessagingMap, err error)
  • func (s *Service) Lookup(matcher *common.MatchDefinition) ([]iface.Serviceable, error)
  • func (s *Service) Publish(ctx context.Context, projectId, appId, channel string, data []byte) error
  • func (s *Service) Subscribe(projectId, appId, path string) error
  • func (s *Service) WebSocketURL(projectId, appId, channel string) (string, error)

Variables

var (
	TheServiceables = []string{string(functionSpec.PathVariable)}
)

Types

type Service

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

func New

func New(srv nodeIface.Service) (*Service, error)

func (*Service) Cache

func (s *Service) Cache() iface.Cache

func (*Service) CheckTns

func (s *Service) CheckTns(_matcher commonIface.MatchDefinition) ([]commonIface.Serviceable, error)

func (*Service) Close

func (s *Service) Close() error

func (*Service) Context

func (s *Service) Context() context.Context

func (*Service) GetMessagingsMap

func (s *Service) GetMessagingsMap(matcher *common.MatchDefinition) (messagingsMap *common.MessagingMap, err error)

func (*Service) Lookup

func (s *Service) Lookup(matcher *common.MatchDefinition) ([]iface.Serviceable, error)

func (*Service) Publish

func (s *Service) Publish(ctx context.Context, projectId, appId, channel string, data []byte) error

func (*Service) Subscribe

func (s *Service) Subscribe(projectId, appId, path string) error

TODO smartops and cache the serviceable

func (*Service) WebSocketURL

func (s *Service) WebSocketURL(projectId, appId, channel string) (string, error)