Documentation
¶
Index ¶
Constants ¶
View Source
const JaegerAgentHostPort = "0.0.0.0:6831"
JaegerAgentHostPort point to the agent deployed with sidecar pattern Deployment should use the default port
Variables ¶
This section is empty.
Functions ¶
func NameFromEvent ¶
Types ¶
type Logger ¶
func MustAddLogger ¶
type Manager ¶
type Manager interface { ListTopics(context.Context) (interface{}, error) CreateTopics(context.Context, OptionCreator, ...string) error DeleteTopics(context.Context, ...string) error io.Closer }
Manager provides basic administrative functions for the messaging system
type Messager ¶
type Messager interface {
Message() interface{}
}
Messager defines a contract for creating a compatible message type
type OptionCreator ¶
type OptionCreator interface {
Options() interface{}
}
OptionCreator defines a contract for making metadata/options for consumer
type StreamReader ¶
type StreamReader interface { io.ReadCloser }
StreamReader reads stuff from a stream
type StreamWriter ¶
type StreamWriter interface { io.WriteCloser }
StreamWriter writes things to a stream
type Tracer ¶
type Tracer struct { opentracing.Tracer // contains filtered or unexported fields }
func MustAddTracer ¶
Directories
¶
Path | Synopsis |
---|---|
example
|
|
Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0
|
Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 Code generated by mockery v1.0.0 |
Click to show internal directories.
Click to hide internal directories.