tracing_sink

Documentation

Index

• type TraceSinkServer
  • func Register(svc *grpc.Server, limit int) (*TraceSinkServer, error)
  • func (s *TraceSinkServer) Append(ctx context.Context, request *pb.AppendRequest) (*empty.Empty, error)
  • func (s *TraceSinkServer) GetAfter(ctx context.Context, request *pb.GetAfterRequest) (*pb.GetAfterResponse, error)
  • func (s *TraceSinkServer) GetPolicy(ctx context.Context, _ *pb.GetPolicyRequest) (*pb.GetPolicyResponse, error)
  • func (s *TraceSinkServer) Reset(ctx context.Context, _ *pb.ResetRequest) (*empty.Empty, error)

Types

type TraceSinkServer

type TraceSinkServer struct {
	pb.UnimplementedTraceSinkServer
	// contains filtered or unexported fields
}

TraceSinkServer defines the interface and associated state for a trace sink instance

func Register

func Register(svc *grpc.Server, limit int) (*TraceSinkServer, error)

Register instantiates a sink service instance, and registers it with the grpc service.

func (*TraceSinkServer) Append

func (s *TraceSinkServer) Append(ctx context.Context, request *pb.AppendRequest) (*empty.Empty, error)

Append adds a trace entry to the list of known entries.

func (*TraceSinkServer) GetAfter

func (s *TraceSinkServer) GetAfter(ctx context.Context, request *pb.GetAfterRequest) (*pb.GetAfterResponse, error)

GetAfter retrieves trace entries starting after the supplied ID. The caller also specifies the maximum number of entries to return in one call, and whether to wait if there are no entries currently outstanding.

func (*TraceSinkServer) GetPolicy

func (s *TraceSinkServer) GetPolicy(ctx context.Context, _ *pb.GetPolicyRequest) (*pb.GetPolicyResponse, error)

GetPolicy supplies information on the range of trace entries held by the sink service, and the limits on how many it will retain.

func (*TraceSinkServer) Reset

func (s *TraceSinkServer) Reset(ctx context.Context, _ *pb.ResetRequest) (*empty.Empty, error)

Reset is a test support function that forcibly resets the instance's state to its initial values.