topics

type Ctx struct {
	Request  Request
	Response *Response
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

type PublishOption func(*v1.TopicPublishRequest)

type Request interface {
	TopicName() string
	Message() map[string]interface{}
}

type Response struct {
	Success bool
}

type SubscribableTopic interface {
	// Allow requests the given permissions to the topic.
	Allow(permission TopicPermission, permissions ...TopicPermission) *TopicClient

	// Subscribe will register and start a subscription handler that will be called for all events from this topic.
	// Valid function signatures for handler are:
	//
	//	func()
	//	func() error
	//	func(*topics.Ctx)
	//	func(*topics.Ctx) error
	//	Handler[topics.Ctx]
	Subscribe(handler interface{})
}

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

type TopicClientIface interface {
	// Name returns the Topic name.
	Name() string

	// Publish will publish the provided events on the topic.
	Publish(ctx context.Context, message map[string]interface{}, options ...PublishOption) error
}

type TopicPermission string