v1

Documentation

Index

• Variables
• func RegisterLogSinkServiceServer(s grpc.ServiceRegistrar, srv LogSinkServiceServer)
• type LogSinkServiceClient
  • func NewLogSinkServiceClient(cc grpc.ClientConnInterface) LogSinkServiceClient
• type LogSinkServiceServer
• type UnimplementedLogSinkServiceServer
  • func (UnimplementedLogSinkServiceServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)
• type UnsafeLogSinkServiceServer
• type WriteRequest
  • func (*WriteRequest) Descriptor() ([]byte, []int)
  • func (x *WriteRequest) GetCallId() string
  • func (x *WriteRequest) GetEntry() *grpc_binarylog_v1.GrpcLogEntry
  • func (x *WriteRequest) GetOrigin() string
  • func (*WriteRequest) ProtoMessage()
  • func (x *WriteRequest) ProtoReflect() protoreflect.Message
  • func (x *WriteRequest) Reset()
  • func (x *WriteRequest) String() string
• type WriteResponse
  • func (*WriteResponse) Descriptor() ([]byte, []int)
  • func (*WriteResponse) ProtoMessage()
  • func (x *WriteResponse) ProtoReflect() protoreflect.Message
  • func (x *WriteResponse) Reset()
  • func (x *WriteResponse) String() string

Variables

var File_root_proto protoreflect.FileDescriptor

var LogSinkService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "influxdata.grpc.binarylogsink.v1.LogSinkService",
	HandlerType: (*LogSinkServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Write",
			Handler:    _LogSinkService_Write_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "root.proto",
}

LogSinkService_ServiceDesc is the grpc.ServiceDesc for LogSinkService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLogSinkServiceServer

func RegisterLogSinkServiceServer(s grpc.ServiceRegistrar, srv LogSinkServiceServer)

Types

type LogSinkServiceClient

type LogSinkServiceClient interface {
	// Receives a GrpcLogEntry
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
}

LogSinkServiceClient is the client API for LogSinkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLogSinkServiceClient

func NewLogSinkServiceClient(cc grpc.ClientConnInterface) LogSinkServiceClient

type LogSinkServiceServer

type LogSinkServiceServer interface {
	// Receives a GrpcLogEntry
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
	// contains filtered or unexported methods
}

LogSinkServiceServer is the server API for LogSinkService service. All implementations must embed UnimplementedLogSinkServiceServer for forward compatibility

type UnimplementedLogSinkServiceServer

type UnimplementedLogSinkServiceServer struct {
}

UnimplementedLogSinkServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedLogSinkServiceServer) Write

func (UnimplementedLogSinkServiceServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

type UnsafeLogSinkServiceServer

type UnsafeLogSinkServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLogSinkServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogSinkServiceServer will result in compilation errors.

type WriteRequest

type WriteRequest struct {

	// A unique ID for the call to enable the receiving server to correctly
	// stitch together conversations from multiple clients (in grpc the call_id
	// field is only unique for each caller).
	// Use some unique property of the workload to generate the ID: something
	// random, or podname + startup time or similar, followed by the actual
	// gRPC call_id.
	// Recall that pod names and IP addresses will usually stay the same across
	// container restarts in k8s.
	CallId string `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"`
	// Text identifier to differentiate where the logs came from, if that's
	// important to you. E.g. if using this API to collect logs for comparison of
	// correctness or performance, you might use this to differentiate them.
	// We'll be using "iox" and "tsm" for our query correctness work.
	// If you don't care about this you can safely put any old string here.
	Origin string `protobuf:"bytes,2,opt,name=origin,proto3" json:"origin,omitempty"`
	// The actual gRPC log entry being written.
	Entry *grpc_binarylog_v1.GrpcLogEntry `protobuf:"bytes,3,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

Request object for sending a gRPC log entry to be written.

func (*WriteRequest) Descriptor

func (*WriteRequest) Descriptor() ([]byte, []int)

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetCallId

func (x *WriteRequest) GetCallId() string

func (*WriteRequest) GetEntry

func (x *WriteRequest) GetEntry() *grpc_binarylog_v1.GrpcLogEntry

func (*WriteRequest) GetOrigin

func (x *WriteRequest) GetOrigin() string

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect

func (x *WriteRequest) ProtoReflect() protoreflect.Message

func (*WriteRequest) Reset

func (x *WriteRequest) Reset()

func (*WriteRequest) String

func (x *WriteRequest) String() string

type WriteResponse

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

Response to the Write request

func (*WriteResponse) Descriptor

func (*WriteResponse) Descriptor() ([]byte, []int)

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect

func (x *WriteResponse) ProtoReflect() protoreflect.Message

func (*WriteResponse) Reset

func (x *WriteResponse) Reset()

func (*WriteResponse) String

func (x *WriteResponse) String() string