streamer

type Client interface {
	PostToConnection(ctx context.Context, connectionID string, data []byte) error
	GetConnection(ctx context.Context, connectionID string) (Connection, error)
	DeleteConnection(ctx context.Context, connectionID string) error
}

type Connection struct {
	ConnectedAt   time.Time
	LastActiveAt  time.Time
	IdentityIP    string
	IdentityAgent string
}

type Option func(*clientOptions)