tracing

type Annotation struct {
	Name        string      `json:"name,omitempty"`
	Value       interface{} `json:"value,omitempty"`
	From        From        `json:"from,omitempty"`
	ContentType string      `json:"contentType,omitempty"`
	IsBinary    bool        `json:"isBinary, omitempty"`
}

type CallerIdentityTrace struct {
	AccountUid  string `json:"acctUid,omitempty"`
	LocationUid string `json:"locationUid, omitempty"`
	DeviceUid   string `json:"deviceUid, omitempty"`
}

type ConsoleTraceWriter struct {
}

type Content struct {
	Request  interface{} `json:"request,omitempty"`
	Response interface{} `json:"response,omitempty"`
	Args     interface{} `json:"args,omitempty"`
	Headers  interface{} `json:"headers,omitempty"`
}

type ContentType string

type Dispatcher struct {
	Log logging.Logger
	// contains filtered or unexported fields
}

type From string

type Host struct {
	IPv4        string
	Port        string
	ServiceName string
}

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

type NopClientTracer struct{}

type NopTracer struct{}

type Receiver struct {
	ReceiverName string
	Writer       TraceMessageWriter
	Log          logging.Logger `inject:""`
}

type RequestTracer interface {
	Annotate(f From, k string, v interface{})
	AnnotateBinary(f From, k string, reader io.Reader, ct string)
	Begin()
	End()
}

type TraceMessage struct {
	Duration    time.Duration `json:"duration"`
	BeganAt     time.Time     `json:"beganAt"`
	Name        string        `json:"name"`
	TraceUid    string        `json:"traceUid"`
	SpanUid     string        `json:"spanUid"`
	PrevSpanUid string        `json:"prevSpanUid,omitempty"`
	Role        string        `json:"role"`              //sender, receiver
	Outcome     string        `json:"outcome,omitempty"` //ok, error
	Content     *Content      `json:"content,omitempty"`
	Host        *Host         `json:"host"`
	Annotations []*Annotation `json:"annotations"`
}

type TraceMessageWriter interface {
	Write(b []byte) (n int, err error)
	Close() error
}

type TraceReceiver interface {
	Name() string
	Receive(*TraceMessage)
	Close()
}

type Tracer interface {
	Annotate(f From, k string, v interface{})
	AnnotateBinary(f From, k string, reader io.Reader, ct string)
	NewRequest(name string, args interface{}, headers map[string][]string) RequestTracer
}