telemetry

package
v0.1.0-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 18, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Telemetry_ListLogMessages_FullMethodName   = "/loggo.api.telemetry.Telemetry/ListLogMessages"
	Telemetry_StreamLogMessages_FullMethodName = "/loggo.api.telemetry.Telemetry/StreamLogMessages"
)

Variables

View Source 
var File_api_telemetry_proto protoreflect.FileDescriptor
View Source 
var Telemetry_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "loggo.api.telemetry.Telemetry",
	HandlerType: (*TelemetryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListLogMessages",
			Handler:    _Telemetry_ListLogMessages_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamLogMessages",
			Handler:       _Telemetry_StreamLogMessages_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/telemetry.proto",
}

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

Functions

func RegisterTelemetryServer 

func RegisterTelemetryServer(s grpc.ServiceRegistrar, srv TelemetryServer)

Types

type ListLogMessagesRequest 

type ListLogMessagesRequest struct {
	From      *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To        *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Filter    *LogFilter             `protobuf:"bytes,3,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	PageSize  int32                  `protobuf:"varint,4,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string                 `protobuf:"bytes,5,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogMessagesRequest) Descriptor deprecated 

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

Deprecated: Use ListLogMessagesRequest.ProtoReflect.Descriptor instead.

func (*ListLogMessagesRequest) GetFilter 

func (x *ListLogMessagesRequest) GetFilter() *LogFilter

func (*ListLogMessagesRequest) GetFrom 

func (x *ListLogMessagesRequest) GetFrom() *timestamppb.Timestamp

func (*ListLogMessagesRequest) GetPageSize 

func (x *ListLogMessagesRequest) GetPageSize() int32

func (*ListLogMessagesRequest) GetPageToken 

func (x *ListLogMessagesRequest) GetPageToken() string

func (*ListLogMessagesRequest) GetTo 

func (x *ListLogMessagesRequest) GetTo() *timestamppb.Timestamp

func (*ListLogMessagesRequest) ProtoMessage 

func (*ListLogMessagesRequest) ProtoMessage()

func (*ListLogMessagesRequest) ProtoReflect 

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

func (*ListLogMessagesRequest) Reset 

func (x *ListLogMessagesRequest) Reset()

func (*ListLogMessagesRequest) String 

func (x *ListLogMessagesRequest) String() string

type ListLogMessagesResponse 

type ListLogMessagesResponse struct {
	Batch *LogBatch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogMessagesResponse) Descriptor deprecated 

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

Deprecated: Use ListLogMessagesResponse.ProtoReflect.Descriptor instead.

func (*ListLogMessagesResponse) GetBatch 

func (x *ListLogMessagesResponse) GetBatch() *LogBatch

func (*ListLogMessagesResponse) ProtoMessage 

func (*ListLogMessagesResponse) ProtoMessage()

func (*ListLogMessagesResponse) ProtoReflect 

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

func (*ListLogMessagesResponse) Reset 

func (x *ListLogMessagesResponse) Reset()

func (*ListLogMessagesResponse) String 

func (x *ListLogMessagesResponse) String() string

type LogBatch 

type LogBatch struct {
	Messages      []*LogMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	NextPageToken string        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*LogBatch) Descriptor deprecated 

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

Deprecated: Use LogBatch.ProtoReflect.Descriptor instead.

func (*LogBatch) GetMessages 

func (x *LogBatch) GetMessages() []*LogMessage

func (*LogBatch) GetNextPageToken 

func (x *LogBatch) GetNextPageToken() string

func (*LogBatch) ProtoMessage 

func (*LogBatch) ProtoMessage()

func (*LogBatch) ProtoReflect 

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

func (*LogBatch) Reset 

func (x *LogBatch) Reset()

func (*LogBatch) String 

func (x *LogBatch) String() string

type LogFilter 

type LogFilter struct {

	// Types that are assignable to Filter:
	//
	//	*LogFilter_Text_
	//	*LogFilter_Scoped_
	//	*LogFilter_And_
	//	*LogFilter_Or_
	//	*LogFilter_Not_
	Filter isLogFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func (*LogFilter) Descriptor deprecated 

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

Deprecated: Use LogFilter.ProtoReflect.Descriptor instead.

func (*LogFilter) GetAnd 

func (x *LogFilter) GetAnd() *LogFilter_And

func (*LogFilter) GetFilter 

func (m *LogFilter) GetFilter() isLogFilter_Filter

func (*LogFilter) GetNot 

func (x *LogFilter) GetNot() *LogFilter_Not

func (*LogFilter) GetOr 

func (x *LogFilter) GetOr() *LogFilter_Or

func (*LogFilter) GetScoped 

func (x *LogFilter) GetScoped() *LogFilter_Scoped

func (*LogFilter) GetText 

func (x *LogFilter) GetText() *LogFilter_Text

func (*LogFilter) ProtoMessage 

func (*LogFilter) ProtoMessage()

func (*LogFilter) ProtoReflect 

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

func (*LogFilter) Reset 

func (x *LogFilter) Reset()

func (*LogFilter) String 

func (x *LogFilter) String() string

type LogFilter_And 

type LogFilter_And struct {
	A *LogFilter `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	B *LogFilter `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	// contains filtered or unexported fields
}

func (*LogFilter_And) Descriptor deprecated 

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

Deprecated: Use LogFilter_And.ProtoReflect.Descriptor instead.

func (*LogFilter_And) GetA 

func (x *LogFilter_And) GetA() *LogFilter

func (*LogFilter_And) GetB 

func (x *LogFilter_And) GetB() *LogFilter

func (*LogFilter_And) ProtoMessage 

func (*LogFilter_And) ProtoMessage()

func (*LogFilter_And) ProtoReflect 

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

func (*LogFilter_And) Reset 

func (x *LogFilter_And) Reset()

func (*LogFilter_And) String 

func (x *LogFilter_And) String() string

type LogFilter_And_ 

type LogFilter_And_ struct {
	And *LogFilter_And `protobuf:"bytes,3,opt,name=and,proto3,oneof"`
}

type LogFilter_Not 

type LogFilter_Not struct {
	A *LogFilter `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	// contains filtered or unexported fields
}

func (*LogFilter_Not) Descriptor deprecated 

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

Deprecated: Use LogFilter_Not.ProtoReflect.Descriptor instead.

func (*LogFilter_Not) GetA 

func (x *LogFilter_Not) GetA() *LogFilter

func (*LogFilter_Not) ProtoMessage 

func (*LogFilter_Not) ProtoMessage()

func (*LogFilter_Not) ProtoReflect 

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

func (*LogFilter_Not) Reset 

func (x *LogFilter_Not) Reset()

func (*LogFilter_Not) String 

func (x *LogFilter_Not) String() string

type LogFilter_Not_ 

type LogFilter_Not_ struct {
	Not *LogFilter_Not `protobuf:"bytes,5,opt,name=not,proto3,oneof"`
}

type LogFilter_Or 

type LogFilter_Or struct {
	A *LogFilter `protobuf:"bytes,1,opt,name=a,proto3" json:"a,omitempty"`
	B *LogFilter `protobuf:"bytes,2,opt,name=b,proto3" json:"b,omitempty"`
	// contains filtered or unexported fields
}

func (*LogFilter_Or) Descriptor deprecated 

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

Deprecated: Use LogFilter_Or.ProtoReflect.Descriptor instead.

func (*LogFilter_Or) GetA 

func (x *LogFilter_Or) GetA() *LogFilter

func (*LogFilter_Or) GetB 

func (x *LogFilter_Or) GetB() *LogFilter

func (*LogFilter_Or) ProtoMessage 

func (*LogFilter_Or) ProtoMessage()

func (*LogFilter_Or) ProtoReflect 

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

func (*LogFilter_Or) Reset 

func (x *LogFilter_Or) Reset()

func (*LogFilter_Or) String 

func (x *LogFilter_Or) String() string

type LogFilter_Or_ 

type LogFilter_Or_ struct {
	Or *LogFilter_Or `protobuf:"bytes,4,opt,name=or,proto3,oneof"`
}

type LogFilter_Scoped 

type LogFilter_Scoped struct {
	Field string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LogFilter_Scoped) Descriptor deprecated 

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

Deprecated: Use LogFilter_Scoped.ProtoReflect.Descriptor instead.

func (*LogFilter_Scoped) GetField 

func (x *LogFilter_Scoped) GetField() string

func (*LogFilter_Scoped) GetValue 

func (x *LogFilter_Scoped) GetValue() string

func (*LogFilter_Scoped) ProtoMessage 

func (*LogFilter_Scoped) ProtoMessage()

func (*LogFilter_Scoped) ProtoReflect 

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

func (*LogFilter_Scoped) Reset 

func (x *LogFilter_Scoped) Reset()

func (*LogFilter_Scoped) String 

func (x *LogFilter_Scoped) String() string

type LogFilter_Scoped_ 

type LogFilter_Scoped_ struct {
	Scoped *LogFilter_Scoped `protobuf:"bytes,2,opt,name=scoped,proto3,oneof"`
}

type LogFilter_Text 

type LogFilter_Text struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*LogFilter_Text) Descriptor deprecated 

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

Deprecated: Use LogFilter_Text.ProtoReflect.Descriptor instead.

func (*LogFilter_Text) GetValue 

func (x *LogFilter_Text) GetValue() string

func (*LogFilter_Text) ProtoMessage 

func (*LogFilter_Text) ProtoMessage()

func (*LogFilter_Text) ProtoReflect 

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

func (*LogFilter_Text) Reset 

func (x *LogFilter_Text) Reset()

func (*LogFilter_Text) String 

func (x *LogFilter_Text) String() string

type LogFilter_Text_ 

type LogFilter_Text_ struct {
	Text *LogFilter_Text `protobuf:"bytes,1,opt,name=text,proto3,oneof"`
}

type LogMessage 

type LogMessage struct {
	Message []byte `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Id      []byte `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessage) Descriptor deprecated 

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

Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.

func (*LogMessage) GetId 

func (x *LogMessage) GetId() []byte

func (*LogMessage) GetMessage 

func (x *LogMessage) GetMessage() []byte

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) ProtoReflect 

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

func (*LogMessage) Reset 

func (x *LogMessage) Reset()

func (*LogMessage) String 

func (x *LogMessage) String() string

type StreamLogMessagesRequest 

type StreamLogMessagesRequest struct {
	From     *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	Filter   *LogFilter             `protobuf:"bytes,2,opt,name=filter,proto3,oneof" json:"filter,omitempty"`
	PageSize int32                  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamLogMessagesRequest) Descriptor deprecated 

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

Deprecated: Use StreamLogMessagesRequest.ProtoReflect.Descriptor instead.

func (*StreamLogMessagesRequest) GetFilter 

func (x *StreamLogMessagesRequest) GetFilter() *LogFilter

func (*StreamLogMessagesRequest) GetFrom 

func (x *StreamLogMessagesRequest) GetFrom() *timestamppb.Timestamp

func (*StreamLogMessagesRequest) GetPageSize 

func (x *StreamLogMessagesRequest) GetPageSize() int32

func (*StreamLogMessagesRequest) ProtoMessage 

func (*StreamLogMessagesRequest) ProtoMessage()

func (*StreamLogMessagesRequest) ProtoReflect 

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

func (*StreamLogMessagesRequest) Reset 

func (x *StreamLogMessagesRequest) Reset()

func (*StreamLogMessagesRequest) String 

func (x *StreamLogMessagesRequest) String() string

type StreamLogMessagesResponse 

type StreamLogMessagesResponse struct {

	// Types that are assignable to Response:
	//
	//	*StreamLogMessagesResponse_Batch
	//	*StreamLogMessagesResponse_Message
	Response isStreamLogMessagesResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*StreamLogMessagesResponse) Descriptor deprecated 

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

Deprecated: Use StreamLogMessagesResponse.ProtoReflect.Descriptor instead.

func (*StreamLogMessagesResponse) GetBatch 

func (x *StreamLogMessagesResponse) GetBatch() *LogBatch

func (*StreamLogMessagesResponse) GetMessage 

func (x *StreamLogMessagesResponse) GetMessage() []byte

func (*StreamLogMessagesResponse) GetResponse 

func (m *StreamLogMessagesResponse) GetResponse() isStreamLogMessagesResponse_Response

func (*StreamLogMessagesResponse) ProtoMessage 

func (*StreamLogMessagesResponse) ProtoMessage()

func (*StreamLogMessagesResponse) ProtoReflect 

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

func (*StreamLogMessagesResponse) Reset 

func (x *StreamLogMessagesResponse) Reset()

func (*StreamLogMessagesResponse) String 

func (x *StreamLogMessagesResponse) String() string

type StreamLogMessagesResponse_Batch 

type StreamLogMessagesResponse_Batch struct {
	Batch *LogBatch `protobuf:"bytes,1,opt,name=batch,proto3,oneof"`
}

type StreamLogMessagesResponse_Message 

type StreamLogMessagesResponse_Message struct {
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3,oneof"`
}

type TelemetryClient 

type TelemetryClient interface {
	ListLogMessages(ctx context.Context, in *ListLogMessagesRequest, opts ...grpc.CallOption) (*ListLogMessagesResponse, error)
	StreamLogMessages(ctx context.Context, in *StreamLogMessagesRequest, opts ...grpc.CallOption) (Telemetry_StreamLogMessagesClient, error)
}

TelemetryClient is the client API for Telemetry 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 NewTelemetryClient 

func NewTelemetryClient(cc grpc.ClientConnInterface) TelemetryClient

type TelemetryServer 

type TelemetryServer interface {
	ListLogMessages(context.Context, *ListLogMessagesRequest) (*ListLogMessagesResponse, error)
	StreamLogMessages(*StreamLogMessagesRequest, Telemetry_StreamLogMessagesServer) error
	// contains filtered or unexported methods
}

TelemetryServer is the server API for Telemetry service. All implementations must embed UnimplementedTelemetryServer for forward compatibility

type Telemetry_StreamLogMessagesClient 

type Telemetry_StreamLogMessagesClient interface {
	Recv() (*StreamLogMessagesResponse, error)
	grpc.ClientStream
}

type Telemetry_StreamLogMessagesServer 

type Telemetry_StreamLogMessagesServer interface {
	Send(*StreamLogMessagesResponse) error
	grpc.ServerStream
}

type UnimplementedTelemetryServer 

type UnimplementedTelemetryServer struct {
}

UnimplementedTelemetryServer must be embedded to have forward compatible implementations.

func (UnimplementedTelemetryServer) ListLogMessages 

func (UnimplementedTelemetryServer) ListLogMessages(context.Context, *ListLogMessagesRequest) (*ListLogMessagesResponse, error)

func (UnimplementedTelemetryServer) StreamLogMessages 

func (UnimplementedTelemetryServer) StreamLogMessages(*StreamLogMessagesRequest, Telemetry_StreamLogMessagesServer) error

type UnsafeTelemetryServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.