Versions in this module Expand all Collapse all v0 v0.7.2 May 23, 2024 Changes in this version type SpanContext + func (s *SpanContext) Sampled() bool v0.7.1 May 21, 2024 v0.7.0 May 20, 2024 Changes in this version type Event + ParentSpan *SpanContext + func (x *Event) GetParentSpan() *SpanContext type EventOpts + ParentSpan *SpanContext type SpanContext + func (s *SpanContext) Sample() bool + type Telemetry struct + LogRecords []*v1.LogRecord + Metrics []*v11.Metric + Spans []*v12.Span + TraceId []byte + func (*Telemetry) Descriptor() ([]byte, []int) + func (*Telemetry) ProtoMessage() + func (x *Telemetry) GetLogRecords() []*v1.LogRecord + func (x *Telemetry) GetMetrics() []*v11.Metric + func (x *Telemetry) GetSpans() []*v12.Span + func (x *Telemetry) GetTraceId() []byte + func (x *Telemetry) ProtoReflect() protoreflect.Message + func (x *Telemetry) Reset() + func (x *Telemetry) String() string v0.6.1 Mar 13, 2024 v0.6.0 Mar 13, 2024 Changes in this version type Category + const Category_ACK type Component + Hash string + func (c *Component) ShortHash() string + func (x *Component) GetHash() string type Event + TraceParent *SpanContext + func (evt *Event) PathSuffix() string + func (evt *Event) RewritePath(path string) + func (x *Event) GetTraceParent() *SpanContext type EventOpts + Timeout time.Duration + TraceParent *SpanContext + type SpanContext struct + Flags uint32 + SpanId []byte + TraceId []byte + TraceState string + func (*SpanContext) Descriptor() ([]byte, []int) + func (*SpanContext) ProtoMessage() + func (x *SpanContext) GetFlags() uint32 + func (x *SpanContext) GetSpanId() []byte + func (x *SpanContext) GetTraceId() []byte + func (x *SpanContext) GetTraceState() string + func (x *SpanContext) ProtoReflect() protoreflect.Message + func (x *SpanContext) Reset() + func (x *SpanContext) String() string v0.5.1 Feb 16, 2024 v0.5.0 Feb 3, 2024 Changes in this version + var Category_name = map[int32]string + var Category_value = map[string]int32 + var File_protobuf_msgs_proto protoreflect.FileDescriptor + var RecordStackTraces bool + var RuleParamRegexp = regexp.MustCompile(`([^\\])({[^}]+})`) + func DelParamOrHeader(httpReq *http.Request, keys ...string) + func GenerateId() string + func GetParamOrHeader(httpReq *http.Request, keys ...string) string + func ReadBody(body io.ReadCloser, header http.Header, maxEventSize int64) ([]byte, error) + type Category int32 + const Category_MESSAGE + const Category_REQUEST + const Category_RESPONSE + const Category_UNKNOWN + func (Category) Descriptor() protoreflect.EnumDescriptor + func (Category) EnumDescriptor() ([]byte, []int) + func (Category) Type() protoreflect.EnumType + func (x Category) Enum() *Category + func (x Category) Number() protoreflect.EnumNumber + func (x Category) String() string + type Code int + const CodeBrokerMismatch + const CodeBrokerUnavailable + const CodeComponentGone + const CodeComponentMismatch + const CodeContentTooLarge + const CodeInvalid + const CodeNotFound + const CodePortUnavailable + const CodeRouteInvalid + const CodeRouteNotFound + const CodeTimeout + const CodeUnauthorized + const CodeUnexpected + const CodeUnknownContentType + const CodeUnsupportedAdapter + type Component struct + App string + BrokerId string + Commit string + Id string + Name string + Type string + func NewComponent(typ api.ComponentType, app, name, commit string) *Component + func NewPlatformComponent(typ api.ComponentType, name, commit string) *Component + func NewTargetComponent(typ api.ComponentType, name string) *Component + func (*Component) Descriptor() ([]byte, []int) + func (*Component) ProtoMessage() + func (c *Component) BrokerSubject() string + func (c *Component) GroupKey() string + func (c *Component) GroupSubject() string + func (c *Component) IsComplete() bool + func (c *Component) IsNameOnly() bool + func (c *Component) Key() string + func (c *Component) ShortCommit() string + func (c *Component) Subject() string + func (lhs *Component) Equal(rhs *Component) bool + func (x *Component) GetApp() string + func (x *Component) GetBrokerId() string + func (x *Component) GetCommit() string + func (x *Component) GetId() string + func (x *Component) GetName() string + func (x *Component) GetType() string + func (x *Component) ProtoReflect() protoreflect.Message + func (x *Component) Reset() + func (x *Component) String() string + type Err struct + func ErrBrokerMismatch(cause ...error) *Err + func ErrBrokerUnavailable(cause ...error) *Err + func ErrComponentGone(cause ...error) *Err + func ErrComponentMismatch(cause ...error) *Err + func ErrContentTooLarge(cause ...error) *Err + func ErrInvalid(cause ...error) *Err + func ErrNotFound(cause ...error) *Err + func ErrPortUnavailable(cause ...error) *Err + func ErrRouteInvalid(cause ...error) *Err + func ErrRouteNotFound(cause ...error) *Err + func ErrTimeout(cause ...error) *Err + func ErrUnauthorized(cause ...error) *Err + func ErrUnexpected(cause ...error) *Err + func ErrUnknownContentType(cause ...error) *Err + func ErrUnsupportedAdapter(cause ...error) *Err + func NewKubeFoxErr(msg string, code Code, grpcCode codes.Code, httpCode int, cause ...error) *Err + func (e *Err) Code() Code + func (e *Err) Error() string + func (e *Err) Format(s fmt.State, verb rune) + func (e *Err) GRPCCode() codes.Code + func (e *Err) GRPCStatus() *status.Status + func (e *Err) HTTPCode() int + func (e *Err) Is(err error) bool + func (e *Err) MarshalJSON() ([]byte, error) + func (e *Err) String() string + func (e *Err) UnmarshalJSON(value []byte) error + func (e *Err) Unwrap() error + type Event struct + Category Category + Content []byte + ContentType string + Context *EventContext + CreateTime int64 + Id string + Params map[string]*structpb.Value + ParentId string + Source *Component + Target *Component + Ttl int64 + Type string + Values map[string]*structpb.Value + func CloneToReq(evt *Event, opts EventOpts) *Event + func CloneToResp(evt *Event, opts EventOpts) *Event + func NewErr(err error, opts EventOpts) *Event + func NewEvent() *Event + func NewMsg(opts EventOpts) *Event + func NewReq(opts EventOpts) *Event + func NewResp(opts EventOpts) *Event + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (evt *Event) AddHeader(key, value string) + func (evt *Event) Bind(v any) error + func (evt *Event) BindStrict(v any) error + func (evt *Event) Bytes() []byte + func (evt *Event) DelHeader(key string) + func (evt *Event) DelQuery(key string) + func (evt *Event) DelValueMapKey(valKey, key string) + func (evt *Event) Err() error + func (evt *Event) EventType() api.EventType + func (evt *Event) HTTPRequest(ctx context.Context) (*http.Request, error) + func (evt *Event) HTTPResponse() *http.Response + func (evt *Event) HasContext() bool + func (evt *Event) Header(key string) string + func (evt *Event) HeaderAll(key string) []string + func (evt *Event) HeaderDef(key string, def string) string + func (evt *Event) HeaderV(key string) *api.Val + func (evt *Event) Param(key string) string + func (evt *Event) ParamDef(key string, def string) string + func (evt *Event) ParamProto(key string) *structpb.Value + func (evt *Event) ParamV(key string) *api.Val + func (evt *Event) Query(key string) string + func (evt *Event) QueryAll(key string) []string + func (evt *Event) QueryDef(key string, def string) string + func (evt *Event) QueryV(key string) *api.Val + func (evt *Event) ReduceTTL(start time.Time) time.Duration + func (evt *Event) SetContext(evtCtx *EventContext) + func (evt *Event) SetHTTPRequest(httpReq *http.Request, maxEventSize int64) error + func (evt *Event) SetHTTPResponse(httpResp *http.Response, maxEventSize int64) error + func (evt *Event) SetHeader(key, value string) + func (evt *Event) SetHeaderV(key string, value *api.Val) + func (evt *Event) SetJSON(v any) error + func (evt *Event) SetParam(key string, val string) + func (evt *Event) SetParamProto(key string, val *structpb.Value) + func (evt *Event) SetParamV(key string, val *api.Val) + func (evt *Event) SetParent(parent *Event) + func (evt *Event) SetQuery(key, value string) + func (evt *Event) SetQueryV(key string, value *api.Val) + func (evt *Event) SetRoute(route *Route) + func (evt *Event) SetSpanId(val string) + func (evt *Event) SetStatus(code int) + func (evt *Event) SetStatusV(val *api.Val) + func (evt *Event) SetTTL(t time.Duration) + func (evt *Event) SetTraceFlags(val byte) + func (evt *Event) SetTraceId(val string) + func (evt *Event) SetURL(u *url.URL) + func (evt *Event) SetValue(key string, val string) + func (evt *Event) SetValueMap(key string, m map[string][]string) + func (evt *Event) SetValueMapKey(valKey, key, value string, overwrite bool) + func (evt *Event) SetValueProto(key string, val *structpb.Value) + func (evt *Event) SetValueV(key string, val *api.Val) + func (evt *Event) SpanId() string + func (evt *Event) Status() int + func (evt *Event) StatusV() *api.Val + func (evt *Event) Str() string + func (evt *Event) TTL() time.Duration + func (evt *Event) TraceFlags() byte + func (evt *Event) TraceId() string + func (evt *Event) TrimPathPrefix(prefix string) + func (evt *Event) URL() (*url.URL, error) + func (evt *Event) Value(key string) string + func (evt *Event) ValueMap(key string) map[string][]string + func (evt *Event) ValueMapKey(valKey, key string) string + func (evt *Event) ValueMapKeyAll(valKey, key string) []string + func (evt *Event) ValueProto(key string) *structpb.Value + func (evt *Event) ValueV(key string) *api.Val + func (x *Event) GetCategory() Category + func (x *Event) GetContent() []byte + func (x *Event) GetContentType() string + func (x *Event) GetContext() *EventContext + func (x *Event) GetCreateTime() int64 + func (x *Event) GetId() string + func (x *Event) GetParams() map[string]*structpb.Value + func (x *Event) GetParentId() string + func (x *Event) GetSource() *Component + func (x *Event) GetTarget() *Component + func (x *Event) GetTtl() int64 + func (x *Event) GetType() string + func (x *Event) GetValues() map[string]*structpb.Value + func (x *Event) ProtoReflect() protoreflect.Message + func (x *Event) Reset() + func (x *Event) String() string + type EventContext struct + AppDeployment string + Platform string + ReleaseManifest string + VirtualEnvironment string + func (*EventContext) Descriptor() ([]byte, []int) + func (*EventContext) ProtoMessage() + func (x *EventContext) GetAppDeployment() string + func (x *EventContext) GetPlatform() string + func (x *EventContext) GetReleaseManifest() string + func (x *EventContext) GetVirtualEnvironment() string + func (x *EventContext) ProtoReflect() protoreflect.Message + func (x *EventContext) Reset() + func (x *EventContext) String() string + type EventOpts struct + Parent *Event + Source *Component + Target *Component + Type api.EventType + type Frame uintptr + func (f Frame) Format(s fmt.State, verb rune) + func (f Frame) MarshalText() ([]byte, error) + type LimitedReader struct + N int64 + R io.Reader + func (l *LimitedReader) Read(p []byte) (n int, err error) + type MatchedEvent struct + Env map[string]*structpb.Value + Event *Event + RouteId int64 + func (*MatchedEvent) Descriptor() ([]byte, []int) + func (*MatchedEvent) ProtoMessage() + func (x *MatchedEvent) GetEnv() map[string]*structpb.Value + func (x *MatchedEvent) GetEvent() *Event + func (x *MatchedEvent) GetRouteId() int64 + func (x *MatchedEvent) ProtoReflect() protoreflect.Message + func (x *MatchedEvent) Reset() + func (x *MatchedEvent) String() string + type Route struct + Component *Component + EventContext *EventContext + Id int + Priority int + ResolvedRule string + func NewRoute(id int, rule string) (*Route, error) + func (r *Route) Resolve(data *api.Data) (err error) + type Stack []uintptr + func (s *Stack) Format(st fmt.State, verb rune) + func (s *Stack) StackTrace() StackTrace + type StackTrace []Frame + func (st StackTrace) Format(s fmt.State, verb rune) v0.4.0-alpha Jan 3, 2024 v0.3.0-alpha Dec 8, 2023
Go to main page