mapperclient

Documentation

Index

• Constants
• type HealthResponse
  • func Health(ctx_ context.Context, client_ graphql.Client) (*HealthResponse, error)
  • func (v *HealthResponse) GetHealth() bool
• type KafkaMapperResult
  • func (v *KafkaMapperResult) GetLastSeen() time.Time
  • func (v *KafkaMapperResult) GetOperation() string
  • func (v *KafkaMapperResult) GetServerNamespace() string
  • func (v *KafkaMapperResult) GetServerPodName() string
  • func (v *KafkaMapperResult) GetSrcIp() string
  • func (v *KafkaMapperResult) GetTopic() string
• type KafkaMapperResults
  • func (v *KafkaMapperResults) GetResults() []KafkaMapperResult
• type MapperClient
  • func NewMapperClient(mapperAddress string) MapperClient

Constants

const Health_Operation = `
query Health {
	health
}
`

The query or mutation executed by Health.

Types

type HealthResponse

type HealthResponse struct {
	Health bool `json:"health"`
}

HealthResponse is returned by Health on success.

func Health

func Health(
	ctx_ context.Context,
	client_ graphql.Client,
) (*HealthResponse, error)

func (*HealthResponse) GetHealth

func (v *HealthResponse) GetHealth() bool

GetHealth returns HealthResponse.Health, and is useful for accessing the field via an interface.

type KafkaMapperResult

type KafkaMapperResult struct {
	SrcIp           string    `json:"srcIp"`
	ServerPodName   string    `json:"serverPodName"`
	ServerNamespace string    `json:"serverNamespace"`
	Topic           string    `json:"topic"`
	Operation       string    `json:"operation"`
	LastSeen        time.Time `json:"lastSeen"`
}

func (*KafkaMapperResult) GetLastSeen

func (v *KafkaMapperResult) GetLastSeen() time.Time

GetLastSeen returns KafkaMapperResult.LastSeen, and is useful for accessing the field via an interface.

func (*KafkaMapperResult) GetOperation

func (v *KafkaMapperResult) GetOperation() string

GetOperation returns KafkaMapperResult.Operation, and is useful for accessing the field via an interface.

func (*KafkaMapperResult) GetServerNamespace

func (v *KafkaMapperResult) GetServerNamespace() string

GetServerNamespace returns KafkaMapperResult.ServerNamespace, and is useful for accessing the field via an interface.

func (*KafkaMapperResult) GetServerPodName

func (v *KafkaMapperResult) GetServerPodName() string

GetServerPodName returns KafkaMapperResult.ServerPodName, and is useful for accessing the field via an interface.

func (*KafkaMapperResult) GetSrcIp

func (v *KafkaMapperResult) GetSrcIp() string

GetSrcIp returns KafkaMapperResult.SrcIp, and is useful for accessing the field via an interface.

func (*KafkaMapperResult) GetTopic

func (v *KafkaMapperResult) GetTopic() string

GetTopic returns KafkaMapperResult.Topic, and is useful for accessing the field via an interface.

type KafkaMapperResults

type KafkaMapperResults struct {
	Results []KafkaMapperResult `json:"results"`
}

func (*KafkaMapperResults) GetResults

func (v *KafkaMapperResults) GetResults() []KafkaMapperResult

GetResults returns KafkaMapperResults.Results, and is useful for accessing the field via an interface.

type MapperClient

type MapperClient interface {
	ReportKafkaMapperResults(ctx context.Context, results KafkaMapperResults) error
	Health(ctx context.Context) error
}

func NewMapperClient

func NewMapperClient(mapperAddress string) MapperClient