carrier

Documentation

Index

• Constants
• type K8sObjAntCarrier
  • func NewK8sAntCarrierFromInterface(objInterface interface{}) (*K8sObjAntCarrier, error)
  • func NewK8sAntCarrierFromObj(obj metav1.Object) (*K8sObjAntCarrier, error)
  • func (objCarrier *K8sObjAntCarrier) Get(key string) string
  • func (objCarrier *K8sObjAntCarrier) Keys() []string
  • func (objCarrier *K8sObjAntCarrier) Set(key string, value string)
• type K8sObjAntCarrier2
  • func NewK8sAntCarrier2FromObj(mp map[string]string) *K8sObjAntCarrier2
  • func (objCarrier *K8sObjAntCarrier2) Get(key string) string
  • func (objCarrier *K8sObjAntCarrier2) Keys() []string
  • func (objCarrier *K8sObjAntCarrier2) Set(key string, value string)

Constants

const KOC_KEY = "eppppi.github.io/koc"

const KOC_PREFIX = "eppppi/koc/"

Types

type K8sObjAntCarrier

type K8sObjAntCarrier struct {
	metav1.Object
}

OpenTelemetry carrier using annotation of kubernetes object TODO: metav1.Objectだけじゃなくてruntime.Object(?)(ReplicaSetとか)でもいいようにしたい

func NewK8sAntCarrierFromInterface

func NewK8sAntCarrierFromInterface(objInterface interface{}) (*K8sObjAntCarrier, error)

func NewK8sAntCarrierFromObj

func NewK8sAntCarrierFromObj(obj metav1.Object) (*K8sObjAntCarrier, error)

func (*K8sObjAntCarrier) Get

func (objCarrier *K8sObjAntCarrier) Get(key string) string

func (*K8sObjAntCarrier) Keys

func (objCarrier *K8sObjAntCarrier) Keys() []string

func (*K8sObjAntCarrier) Set

func (objCarrier *K8sObjAntCarrier) Set(key string, value string)

type K8sObjAntCarrier2

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

func NewK8sAntCarrier2FromObj

func NewK8sAntCarrier2FromObj(mp map[string]string) *K8sObjAntCarrier2

func (*K8sObjAntCarrier2) Get

func (objCarrier *K8sObjAntCarrier2) Get(key string) string

func (*K8sObjAntCarrier2) Keys

func (objCarrier *K8sObjAntCarrier2) Keys() []string

func (*K8sObjAntCarrier2) Set

func (objCarrier *K8sObjAntCarrier2) Set(key string, value string)