plogotlp

Documentation

Index

• func RegisterGRPCServer(s *grpc.Server, srv GRPCServer)
• type ExportPartialSuccess
  • func NewExportPartialSuccess() ExportPartialSuccess
  • func (ms ExportPartialSuccess) CopyTo(dest ExportPartialSuccess)
  • func (ms ExportPartialSuccess) ErrorMessage() string
  • func (ms ExportPartialSuccess) MoveTo(dest ExportPartialSuccess)
  • func (ms ExportPartialSuccess) RejectedLogRecords() int64
  • func (ms ExportPartialSuccess) SetErrorMessage(v string)
  • func (ms ExportPartialSuccess) SetRejectedLogRecords(v int64)
• type ExportRequest
  • func NewExportRequest() ExportRequest
  • func NewExportRequestFromLogs(ld plog.Logs) ExportRequest
  • func (ms ExportRequest) Logs() plog.Logs
  • func (ms ExportRequest) MarshalJSON() ([]byte, error)
  • func (ms ExportRequest) MarshalProto() ([]byte, error)
  • func (ms ExportRequest) UnmarshalJSON(data []byte) error
  • func (ms ExportRequest) UnmarshalProto(data []byte) error
• type ExportResponse
  • func NewExportResponse() ExportResponse
  • func (lr ExportResponse) MarshalJSON() ([]byte, error)
  • func (lr ExportResponse) MarshalProto() ([]byte, error)
  • func (lr ExportResponse) PartialSuccess() ExportPartialSuccess
  • func (lr ExportResponse) UnmarshalJSON(data []byte) error
  • func (lr ExportResponse) UnmarshalProto(data []byte) error
• type GRPCClient
  • func NewGRPCClient(cc *grpc.ClientConn) GRPCClient
• type GRPCServer
• type UnimplementedGRPCServer
  • func (*UnimplementedGRPCServer) Export(context.Context, ExportRequest) (ExportResponse, error)

Functions

func RegisterGRPCServer

func RegisterGRPCServer(s *grpc.Server, srv GRPCServer)

RegisterGRPCServer registers the Server to the grpc.Server.

Types

type ExportPartialSuccess

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

ExportPartialSuccess represents the details of a partially successful export request.

This is a reference type, if passed by value and callee modifies it the caller will see the modification.

Must use NewExportPartialSuccess function to create new instances. Important: zero-initialized instance is not valid for use.

func NewExportPartialSuccess

func NewExportPartialSuccess() ExportPartialSuccess

NewExportPartialSuccess creates a new empty ExportPartialSuccess.

This must be used only in testing code. Users should use "AppendEmpty" when part of a Slice, OR directly access the member if this is embedded in another struct.

func (ExportPartialSuccess) CopyTo

func (ms ExportPartialSuccess) CopyTo(dest ExportPartialSuccess)

CopyTo copies all properties from the current struct overriding the destination.

func (ExportPartialSuccess) ErrorMessage

func (ms ExportPartialSuccess) ErrorMessage() string

ErrorMessage returns the errormessage associated with this ExportPartialSuccess.

func (ExportPartialSuccess) MoveTo

func (ms ExportPartialSuccess) MoveTo(dest ExportPartialSuccess)

MoveTo moves all properties from the current struct overriding the destination and resetting the current instance to its zero value

func (ExportPartialSuccess) RejectedLogRecords

func (ms ExportPartialSuccess) RejectedLogRecords() int64

RejectedLogRecords returns the rejectedlogrecords associated with this ExportPartialSuccess.

func (ExportPartialSuccess) SetErrorMessage

func (ms ExportPartialSuccess) SetErrorMessage(v string)

SetErrorMessage replaces the errormessage associated with this ExportPartialSuccess.

func (ExportPartialSuccess) SetRejectedLogRecords

func (ms ExportPartialSuccess) SetRejectedLogRecords(v int64)

SetRejectedLogRecords replaces the rejectedlogrecords associated with this ExportPartialSuccess.

type ExportRequest

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

ExportRequest represents the request for gRPC/HTTP client/server. It's a wrapper for plog.Logs data.

func NewExportRequest

func NewExportRequest() ExportRequest

NewExportRequest returns an empty ExportRequest.

func NewExportRequestFromLogs

func NewExportRequestFromLogs(ld plog.Logs) ExportRequest

NewExportRequestFromLogs returns a ExportRequest from plog.Logs. Because ExportRequest is a wrapper for plog.Logs, any changes to the provided Logs struct will be reflected in the ExportRequest and vice versa.

func (ExportRequest) Logs

func (ms ExportRequest) Logs() plog.Logs

func (ExportRequest) MarshalJSON

func (ms ExportRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals ExportRequest into JSON bytes.

func (ExportRequest) MarshalProto

func (ms ExportRequest) MarshalProto() ([]byte, error)

MarshalProto marshals ExportRequest into proto bytes.

func (ExportRequest) UnmarshalJSON

func (ms ExportRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshalls ExportRequest from JSON bytes.

func (ExportRequest) UnmarshalProto

func (ms ExportRequest) UnmarshalProto(data []byte) error

UnmarshalProto unmarshalls ExportRequest from proto bytes.

type ExportResponse

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

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

func NewExportResponse

func NewExportResponse() ExportResponse

NewExportResponse returns an empty ExportResponse.

func (ExportResponse) MarshalJSON

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

MarshalJSON marshals ExportResponse into JSON bytes.

func (ExportResponse) MarshalProto

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

MarshalProto marshals ExportResponse into proto bytes.

func (ExportResponse) PartialSuccess

func (lr ExportResponse) PartialSuccess() ExportPartialSuccess

PartialSuccess returns the ExportPartialSuccess associated with this ExportResponse.

func (ExportResponse) UnmarshalJSON

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

UnmarshalJSON unmarshalls ExportResponse from JSON bytes.

func (ExportResponse) UnmarshalProto

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

UnmarshalProto unmarshalls ExportResponse from proto bytes.

type GRPCClient

type GRPCClient 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 ExportRequest, opts ...grpc.CallOption) (ExportResponse, error)
	// contains filtered or unexported methods
}

GRPCClient 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 NewGRPCClient

func NewGRPCClient(cc *grpc.ClientConn) GRPCClient

NewGRPCClient returns a new GRPCClient connected using the given connection.

type GRPCServer

type GRPCServer 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, ExportRequest) (ExportResponse, error)
	// contains filtered or unexported methods
}

GRPCServer is the server API for OTLP gRPC LogsService service. Implementations MUST embed UnimplementedGRPCServer.

type UnimplementedGRPCServer

type UnimplementedGRPCServer struct{}

UnimplementedGRPCServer MUST be embedded to have forward compatible implementations.

func (*UnimplementedGRPCServer) Export

func (*UnimplementedGRPCServer) Export(context.Context, ExportRequest) (ExportResponse, error)