types

Documentation

Index

• type FixedSizeObserver
• type GrpcClient
• type GrpcStreamDecorator
• type Observer

Types

type FixedSizeObserver

type FixedSizeObserver[T interface{}] interface {
	Publish(element T) uint64
	Subscribe(ctx context.Context) <-chan T
	GetLength() int
	Release()
	Ack(msgId uint64)
	WaitAck(msgId uint64)
}

type GrpcClient

type GrpcClient[T interface{}] interface {
	GetId() uuid.UUID
	SetId(id uuid.UUID)
	HasId() bool
	Stop()
	GetContext() context.Context
	Listen() error
}

type GrpcStreamDecorator

type GrpcStreamDecorator[I interface{}, O interface{}] interface {
	Fetch() (<-chan O, error)
	Release()
	GetStreamContext() context.Context
}

type Observer

type Observer[T interface{}] interface {
	Publish(element T) bool
	PublishWithWaiting(ctx context.Context, element T)
	Subscribe(func(T) bool) uint64
	Unsubscribe(id uint64)
	Release()
}