trace_sink

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

Functions

func Append

func Append(ctx context.Context, entry *log.Entry) error

Append adds a log entry to the trace sink

func GetPolicy

func GetPolicy(ctx context.Context) (*pb.GetPolicyResponse, error)

GetPolicy obtains the current trace sink policy and returns it

func GetTraces

func GetTraces(
	ctx context.Context,
	start int64,
	maxCount int64) <-chan traceData

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.

func Reset

func Reset(ctx context.Context) error

Reset forcibly resets the trace sink to its initial state. This is intended to support unit tests