pubsub

Documentation

Index

• type System
  • func NewSystem() *System
  • func (s *System) CloseConnection(connection string) error
  • func (s *System) Publish(ctx context.Context, connection string, topic string, msg interface{}) error
  • func (s *System) UpsertConnection(ctx context.Context, config interface{}, name string, provider string) error

Types

type System

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

func NewSystem

func NewSystem() *System

func (*System) CloseConnection

func (s *System) CloseConnection(connection string) error

func (*System) Publish

func (s *System) Publish(ctx context.Context, connection string, topic string, msg interface{}) error

func (*System) UpsertConnection

func (s *System) UpsertConnection(ctx context.Context, config interface{}, name string, provider string) error