api

Documentation

Index

• Variables
• type ChangeEvent
  • func NewK8sChangeEvent(oldObj, newObj *unstructured.Unstructured) *ChangeEvent
  • func NewKafkaChangeEvent(oldObj, newObj interface{}, apiKey string) *ChangeEvent
• type Client
• type EventType
• type IssueRequest
• type NoOpClient
  • func (nc *NoOpClient) SendAgentInfo() error
  • func (nc *NoOpClient) SendChangeEvent(*ChangeEvent) error
  • func (nc *NoOpClient) SendIssue(request *IssueRequest) error
  • func (nc *NoOpClient) SendK8sResources(*ResourceList) error
  • func (nc *NoOpClient) SendTrafficMetrics(*prompb.WriteRequest) error
• type ResourceList
  • func NewResourceList(objects []runtime.Object) *ResourceList

Variables

var RedactEnvVar = false

Types

type ChangeEvent

type ChangeEvent struct {
	OldObject *unstructured.Unstructured `json:"old_object"`
	NewObject *unstructured.Unstructured `json:"new_object"`
	EventType EventType                  `json:"event_type"`
	Time      int64                      `json:"time"`
}

func NewK8sChangeEvent

func NewK8sChangeEvent(oldObj, newObj *unstructured.Unstructured) *ChangeEvent

func NewKafkaChangeEvent

func NewKafkaChangeEvent(oldObj, newObj interface{}, apiKey string) *ChangeEvent

type Client

type Client interface {
	SendChangeEvent(*ChangeEvent) error
	SendK8sResources(*ResourceList) error
	SendTrafficMetrics(*prompb.WriteRequest) error
	SendIssue(*IssueRequest) error
	SendAgentInfo() error
}

type EventType

type EventType string

const (
	ObjectAdd    EventType = "object_add"
	ObjectUpdate EventType = "object_update"
	ObjectDelete EventType = "object_delete"
	KafkaUpdate  EventType = "kafka_update"
)

type IssueRequest

type IssueRequest struct {
	IssueSource string `json:"issue_source"`
	Data        string `json:"data"`
}

type NoOpClient

type NoOpClient struct {
}

func (*NoOpClient) SendAgentInfo

func (nc *NoOpClient) SendAgentInfo() error

func (*NoOpClient) SendChangeEvent

func (nc *NoOpClient) SendChangeEvent(*ChangeEvent) error

func (*NoOpClient) SendIssue

func (nc *NoOpClient) SendIssue(request *IssueRequest) error

func (*NoOpClient) SendK8sResources

func (nc *NoOpClient) SendK8sResources(*ResourceList) error

func (*NoOpClient) SendTrafficMetrics

func (nc *NoOpClient) SendTrafficMetrics(*prompb.WriteRequest) error

type ResourceList

type ResourceList struct {
	Objects []runtime.Object `json:"objects"`
	Time    int64            `json:"time"`
}

func NewResourceList

func NewResourceList(objects []runtime.Object) *ResourceList