taskmanager

Documentation

Index

• Constants
• type Manager
  • func NewManager(firestoreClient *firestore.Client) *Manager
  • func (m *Manager) PublishToAssociation(ctx context.Context, targetID string, taskType string, payload []byte) error
  • func (m *Manager) PublishToManager(ctx context.Context, targetID string, taskType string, payload []byte) error
  • func (m *Manager) SetSubscribeHandler(handler SubscribeHandler)
  • func (m *Manager) StartManager(id string, associationID string, errorCh chan error)
• type SubscribeHandler

Constants

const (
	PrefixManager     = "MANAGER_"
	PrefixAssociation = "ASSOCIATION_"
)

Types

type Manager

type Manager struct {
	ID              string
	AssociationID   string
	FirestoreClient *firestore.Client
	Mu              sync.Mutex
	// contains filtered or unexported fields
}

func NewManager

func NewManager(firestoreClient *firestore.Client) *Manager

func (*Manager) PublishToAssociation

func (m *Manager) PublishToAssociation(
	ctx context.Context,
	targetID string,
	taskType string,
	payload []byte,
) error

func (*Manager) PublishToManager

func (m *Manager) PublishToManager(
	ctx context.Context,
	targetID string,
	taskType string,
	payload []byte,
) error

func (*Manager) SetSubscribeHandler

func (m *Manager) SetSubscribeHandler(handler SubscribeHandler)

func (*Manager) StartManager

func (m *Manager) StartManager(
	id string,
	associationID string,
	errorCh chan error,
)

type SubscribeHandler

type SubscribeHandler func(string, []byte) error