topic

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

type Executor interface {
	// Execute should perform actions corresponding to the provided command. The returned error should correspond
	// to the issue relevant to the command. For example, a command that creates a new Topic should return
	// ErrTopicExists if the topic already exists.
	Execute(ctx context.Context, cmd command.Command) error
}

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

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

type Manager interface {
	Create(ctx context.Context, t *topic.Topic) error
	Delete(ctx context.Context, t string) error
}

type NodeLister interface {
	// List should return all node records in the state.
	List(ctx context.Context) ([]*nodepb.Node, error)
}

type Querier interface {
	// Get should return the Topic corresponding to the given name. It should return ErrNoTopic if the
	// named topic does not exist. It should return ErrNoTopicInfo if incomplete topic data is found.
	Get(ctx context.Context, name string) (*topic.Topic, error)

	// List should return a slice of all Topics the node has knowledge of. It should return ErrNoTopicInfo if
	// incomplete topic data is found.
	List(ctx context.Context) ([]*topic.Topic, error)
}