pubsub

Documentation

Index

• type Handler
• type Service
  • func Get() Service
  • func New(client *redis.Client) Service
• type Topic

Types

type Handler

type Handler interface{}

Handler is an interface and will contain target function to run in subscriber

type Service

type Service interface {
	Publish(ctx context.Context, topic string, msg proto.Message) error
	Subscribe(ctx context.Context, topic string, handler Handler)
}

Service pubsub service

func Get

func Get() Service

Get return pubsub service instance

func New

func New(client *redis.Client) Service

New create a new instance of pubsub service

type Topic

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

Topic topic holder that contain handlers lists