http

Documentation

Index

• type Bus
• type HttpSignalServiceImpl
  • func NewHttpSignalServiceImpl(bus Bus[string]) *HttpSignalServiceImpl
  • func (h *HttpSignalServiceImpl) Recv(ctx context.Context, inbox string) (msgs <-chan string, err error)
  • func (h *HttpSignalServiceImpl) Send(ctx context.Context, inbox string, msg string) (err error)
• type MemoryBus
  • func NewMemoryBus[T any]() *MemoryBus[T]
  • func (m *MemoryBus[T]) Recv(ctx context.Context, inbox string) (msgs <-chan T, err error)
  • func (m *MemoryBus[T]) Send(ctx context.Context, inbox string, msg T) (err error)

Types

type Bus

type Bus[T any] interface {
	Send(ctx context.Context, inbox string, msg T) (err error)
	Recv(ctx context.Context, inbox string) (msgs <-chan T, err error)
}

type HttpSignalServiceImpl

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

func NewHttpSignalServiceImpl

func NewHttpSignalServiceImpl(bus Bus[string]) *HttpSignalServiceImpl

func (*HttpSignalServiceImpl) Recv

func (h *HttpSignalServiceImpl) Recv(ctx context.Context, inbox string) (msgs <-chan string, err error)

func (*HttpSignalServiceImpl) Send

func (h *HttpSignalServiceImpl) Send(ctx context.Context, inbox string, msg string) (err error)

type MemoryBus

type MemoryBus[T any] struct {
	// contains filtered or unexported fields
}

func NewMemoryBus

func NewMemoryBus[T any]() *MemoryBus[T]

func (*MemoryBus[T]) Recv

func (m *MemoryBus[T]) Recv(ctx context.Context, inbox string) (msgs <-chan T, err error)

func (*MemoryBus[T]) Send

func (m *MemoryBus[T]) Send(ctx context.Context, inbox string, msg T) (err error)