plogotlp

Documentation

Index

• func RegisterServer(s *grpc.Server, srv Server)
• type Client
  • func NewClient(cc *grpc.ClientConn) Client
• type Request
  • func NewRequest() Request
  • func (lr Request) Logs() plog.Logs
  • func (lr Request) MarshalJSON() ([]byte, error)
  • func (lr Request) MarshalProto() ([]byte, error)
  • func (lr Request) SetLogs(ld plog.Logs)
  • func (lr Request) UnmarshalJSON(data []byte) error
  • func (lr Request) UnmarshalProto(data []byte) error
• type Response
  • func NewResponse() Response
  • func (lr Response) MarshalJSON() ([]byte, error)
  • func (lr Response) MarshalProto() ([]byte, error)
  • func (lr Response) UnmarshalJSON(data []byte) error
  • func (lr Response) UnmarshalProto(data []byte) error
• type Server

Functions

func RegisterServer

func RegisterServer(s *grpc.Server, srv Server)

RegisterServer registers the Server to the grpc.Server.

Types

type Client

type Client interface {
	// Export plog.Logs to the server.
	//
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	Export(ctx context.Context, request Request, opts ...grpc.CallOption) (Response, error)
}

Client is the client API for OTLP-GRPC Logs service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewClient

func NewClient(cc *grpc.ClientConn) Client

NewClient returns a new Client connected using the given connection.

type Request

type Request struct {
	// contains filtered or unexported fields
}

Request represents the request for gRPC/HTTP client/server.

func NewRequest

func NewRequest() Request

NewRequest returns an empty Request.

func (Request) Logs

func (lr Request) Logs() plog.Logs

func (Request) MarshalJSON

func (lr Request) MarshalJSON() ([]byte, error)

MarshalJSON marshals Request into JSON bytes.

func (Request) MarshalProto

func (lr Request) MarshalProto() ([]byte, error)

MarshalProto marshals Request into proto bytes.

func (Request) SetLogs

func (lr Request) SetLogs(ld plog.Logs)

func (Request) UnmarshalJSON

func (lr Request) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls Request from JSON bytes.

func (Request) UnmarshalProto

func (lr Request) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls Request from proto bytes.

type Response

type Response struct {
	// contains filtered or unexported fields
}

Response represents the response for gRPC/HTTP client/server.

func NewResponse

func NewResponse() Response

NewResponse returns an empty Response.

func (Response) MarshalJSON

func (lr Response) MarshalJSON() ([]byte, error)

MarshalJSON marshals Response into JSON bytes.

func (Response) MarshalProto

func (lr Response) MarshalProto() ([]byte, error)

MarshalProto marshals Response into proto bytes.

func (Response) UnmarshalJSON

func (lr Response) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls Response from JSON bytes.

func (Response) UnmarshalProto

func (lr Response) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls Response from proto bytes.

type Server

type Server interface {
	// Export is called every time a new request is received.
	//
	// For performance reasons, it is recommended to keep this RPC
	// alive for the entire life of the application.
	Export(context.Context, Request) (Response, error)
}

Server is the server API for OTLP gRPC LogsService service.