topicresolver

Documentation

Index

• type NamespacedTopicResolver
  • func NewNamespacedTopicResolver(template string) (*NamespacedTopicResolver, error)
  • func (r NamespacedTopicResolver) Resolve(_ context.Context, namespace string) (string, error)
• type Resolver

Types

type NamespacedTopicResolver

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

func NewNamespacedTopicResolver

func NewNamespacedTopicResolver(template string) (*NamespacedTopicResolver, error)

func (NamespacedTopicResolver) Resolve

func (r NamespacedTopicResolver) Resolve(_ context.Context, namespace string) (string, error)

type Resolver

type Resolver interface {
	Resolve(ctx context.Context, namespace string) (string, error)
}

Resolver use provided namespace to return a topic name belongs to that namespace.