helium

Documentation

Index

• type Helium
  • func New(ctx context.Context, config types.GRPCConfig, store store.Store) *Helium
  • func (h *Helium) Subscribe(ctx context.Context) (uuid.UUID, <-chan types.ServiceStatus)
  • func (h *Helium) Unsubscribe(ID uuid.UUID)

Types

type Helium

type Helium struct {
	sync.Once
	// contains filtered or unexported fields
}

Helium .

func New

func New(ctx context.Context, config types.GRPCConfig, store store.Store) *Helium

New .

func (*Helium) Subscribe

func (h *Helium) Subscribe(ctx context.Context) (uuid.UUID, <-chan types.ServiceStatus)

Subscribe .

func (*Helium) Unsubscribe

func (h *Helium) Unsubscribe(ID uuid.UUID)

Unsubscribe .