kafka

Documentation

Index

• Variables
• type Client
  • func NewClient(informers k8s.ClusterInformers, log logrus.FieldLogger, db database.TeamRepo) *Client
  • func (c *Client) Search(ctx context.Context, q string, filter *model.SearchFilter) []*search.Result
  • func (c *Client) SupportsSearchFilter(filter *model.SearchFilter) bool
  • func (c *Client) Topic(env string, teamSlug slug.Slug, topicName string) (*model.KafkaTopic, error)
  • func (c *Client) Topics(teamSlug slug.Slug) ([]*model.KafkaTopic, error)

Variables

var (
	KafkaListErrorCounter, _ = otel.Meter("").Int64Counter("kafka_list_errors_total")
	KafkaListOpsCounter, _   = otel.Meter("").Int64Counter("kafka_list_ops_total")
	KafkaErrorCounter, _     = otel.Meter("").Int64Counter("kafka_errors_total")
	KafkaOpsCounter, _       = otel.Meter("").Int64Counter("kafka_ops_total")
)

Types

type Client

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

func NewClient

func NewClient(informers k8s.ClusterInformers, log logrus.FieldLogger, db database.TeamRepo) *Client

func (*Client) Search

func (c *Client) Search(ctx context.Context, q string, filter *model.SearchFilter) []*search.Result

func (*Client) SupportsSearchFilter

func (c *Client) SupportsSearchFilter(filter *model.SearchFilter) bool

func (*Client) Topic

func (c *Client) Topic(env string, teamSlug slug.Slug, topicName string) (*model.KafkaTopic, error)

func (*Client) Topics

func (c *Client) Topics(teamSlug slug.Slug) ([]*model.KafkaTopic, error)