app

type AuthorizeCommandInput struct {
	Channel string
	Payload Batch
}

type Batch []Payload

type Batcher interface {
	Batch([]Payload) []Batch
}

type Clock interface {
	NewTimer(time.Duration) Timer
	Now() time.Time
}

type Codec interface {
	Encoder
	Decoder
}

type Decoder interface {
	Decode(Payload) (Message, error)
}

type Encoder interface {
	Encode(Frame) (Payload, error)
}

type Frame interface {
	ID() string
	Encode() (Payload, error)
}

type FrameBuilder interface {
	WithPayload(Payload) FrameBuilder
	WithBatch(Batch) FrameBuilder
	WithChannel(string) FrameBuilder
	WithSignature(Signature) FrameBuilder
	WithType(string) FrameBuilder
	WithID(string) FrameBuilder
	Build() Frame
}

type FrameBuilderFactory interface {
	Create() FrameBuilder
}

type Heartbeat interface {
	Start(context.Context, time.Duration) error
	Reset()
}

type Inbox interface {
	Next(context.Context) (Message, error)
}

type Logger interface {
	Debug(string, ...any)
	SetContext(string) Logger
}

type Message any

type Payload []byte

type RequestAuthorizer interface {
	Authorize(context.Context, AuthorizeCommandInput) (Signature, error)
}

type Router interface {
	Handle(context.Context, Message) error
}

type SendMessageService interface {
	Send(context.Context, Frame) error
}

type Signature map[string]string

type Timer interface {
	C() <-chan time.Time
	Stop() bool
	Reset(time.Duration)
}