broker

type Broker struct {
	ID string

	Sessions SessionStore
	Queues   QueuesStore
	Messages *messages.Client
	// contains filtered or unexported fields
}

type Config struct {
	AuthHelper func(transport transport.Metadata, sessionID []byte, username string, password string) (tenant string, err error)
	Session    SessionConfig
}

type MessagesStore interface {
	Put(ctx context.Context, streamId string, shardKey string, payload []byte) error
}

type QueuesStore interface {
	Create(ctx context.Context, id string) error
	Delete(ctx context.Context, id string) error
}

type SessionConfig struct {
	MaxInflightSize int
}

type SessionStore interface {
	RefreshKeepAlive(ctx context.Context, id string, timestamp int64) error
}

type Token struct {
	SessionID     string `json:"session_id"`
	SessionTenant string `json:"session_tenant"`
	jwt.StandardClaims
}

type TopicStore interface {
	ByTopicPattern(ctx context.Context, tenant string, pattern []byte) ([]*topics.RetainedMessage, error)
}