topics

Documentation

Index

• type ActionState
• type LocalTopicsAndSubscribersService
  • func NewLocalTopicsService() (*LocalTopicsAndSubscribersService, error)
  • func (s *LocalTopicsAndSubscribersService) GetSubscribers() map[string]map[string]int
  • func (s *LocalTopicsAndSubscribersService) Publish(ctx context.Context, req *topicspb.TopicPublishRequest) (*topicspb.TopicPublishResponse, error)
  • func (s *LocalTopicsAndSubscribersService) Subscribe(stream topicspb.Subscriber_SubscribeServer) error
  • func (s *LocalTopicsAndSubscribersService) SubscribeToAction(subscription func(ActionState))
  • func (s *LocalTopicsAndSubscribersService) SubscribeToState(subscription func(State))
• type State

Types

type ActionState

type ActionState struct {
	TopicName string
	Payload   string
	Success   bool
}

type LocalTopicsAndSubscribersService

type LocalTopicsAndSubscribersService struct {
	*topics.SubscriberManager
	// contains filtered or unexported fields
}

func NewLocalTopicsService

func NewLocalTopicsService() (*LocalTopicsAndSubscribersService, error)

Create new Dev EventService

func (*LocalTopicsAndSubscribersService) GetSubscribers

func (s *LocalTopicsAndSubscribersService) GetSubscribers() map[string]map[string]int

func (*LocalTopicsAndSubscribersService) Publish

func (s *LocalTopicsAndSubscribersService) Publish(ctx context.Context, req *topicspb.TopicPublishRequest) (*topicspb.TopicPublishResponse, error)

Publish a message to a given topic

func (*LocalTopicsAndSubscribersService) Subscribe

func (s *LocalTopicsAndSubscribersService) Subscribe(stream topicspb.Subscriber_SubscribeServer) error

Subscribe to a topic and handle incoming messages

func (*LocalTopicsAndSubscribersService) SubscribeToAction

func (s *LocalTopicsAndSubscribersService) SubscribeToAction(subscription func(ActionState))

func (*LocalTopicsAndSubscribersService) SubscribeToState

func (s *LocalTopicsAndSubscribersService) SubscribeToState(subscription func(State))

type State

type State = map[topicName]map[serviceName]int