Documentation ¶
Index ¶
- func Append(ctx context.Context, entry *log.Entry) error
- func GetPolicy(ctx context.Context) (*pb.GetPolicyResponse, error)
- func GetTraces(ctx context.Context, start int64, maxCount int64) <-chan traceData
- func InitSinkClient(name string, opts ...grpc.DialOption) error
- func Reset(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPolicy ¶
func GetPolicy(ctx context.Context) (*pb.GetPolicyResponse, error)
GetPolicy obtains the current trace sink policy and returns it
func GetTraces ¶
GetTraces retrieves up to the specified limit of trace entries, from the specified starting point. It will always wait for at least one non-internal entry before returning.
func InitSinkClient ¶
func InitSinkClient(name string, opts ...grpc.DialOption) error
InitSinkClient stores the information needed to be able to connect to the Stepper service.
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.