analytics

Documentation

Index

• Variables
• func RegisterAnalyticsServer(s grpc.ServiceRegistrar, srv AnalyticsServer)
• type AnalyticsClient
  • func NewAnalyticsClient(cc grpc.ClientConnInterface) AnalyticsClient
• type AnalyticsEntryMessage
  • func (*AnalyticsEntryMessage) Descriptor() ([]byte, []int)
  • func (x *AnalyticsEntryMessage) GetMethod() string
  • func (x *AnalyticsEntryMessage) GetService() string
  • func (x *AnalyticsEntryMessage) GetTransport() string
  • func (*AnalyticsEntryMessage) ProtoMessage()
  • func (x *AnalyticsEntryMessage) ProtoReflect() protoreflect.Message
  • func (x *AnalyticsEntryMessage) Reset()
  • func (x *AnalyticsEntryMessage) String() string
• type AnalyticsServer
• type GetLogsMessage
  • func (*GetLogsMessage) Descriptor() ([]byte, []int)
  • func (x *GetLogsMessage) GetLogs() []*AnalyticsEntryMessage
  • func (*GetLogsMessage) ProtoMessage()
  • func (x *GetLogsMessage) ProtoReflect() protoreflect.Message
  • func (x *GetLogsMessage) Reset()
  • func (x *GetLogsMessage) String() string
• type LogDataRequest
  • func (*LogDataRequest) Descriptor() ([]byte, []int)
  • func (x *LogDataRequest) GetMethod() string
  • func (x *LogDataRequest) GetService() string
  • func (x *LogDataRequest) GetTransport() string
  • func (*LogDataRequest) ProtoMessage()
  • func (x *LogDataRequest) ProtoReflect() protoreflect.Message
  • func (x *LogDataRequest) Reset()
  • func (x *LogDataRequest) String() string
• type UnimplementedAnalyticsServer
  • func (UnimplementedAnalyticsServer) GetLog(context.Context, *emptypb.Empty) (*GetLogsMessage, error)
  • func (UnimplementedAnalyticsServer) LogData(context.Context, *LogDataRequest) (*emptypb.Empty, error)
• type UnsafeAnalyticsServer

Variables

var Analytics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "analytics.Analytics",
	HandlerType: (*AnalyticsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LogData",
			Handler:    _Analytics_LogData_Handler,
		},
		{
			MethodName: "GetLog",
			Handler:    _Analytics_GetLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "analytics/analytics.proto",
}

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

var File_analytics_analytics_proto protoreflect.FileDescriptor

Functions

func RegisterAnalyticsServer

func RegisterAnalyticsServer(s grpc.ServiceRegistrar, srv AnalyticsServer)

Types

type AnalyticsClient

type AnalyticsClient interface {
	// Connect a client
	LogData(ctx context.Context, in *LogDataRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Get a log
	GetLog(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLogsMessage, error)
}

AnalyticsClient is the client API for Analytics 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 NewAnalyticsClient

func NewAnalyticsClient(cc grpc.ClientConnInterface) AnalyticsClient

type AnalyticsEntryMessage

type AnalyticsEntryMessage struct {
	Transport string `protobuf:"bytes,1,opt,name=transport,proto3" json:"transport,omitempty"`
	Service   string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Method    string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

Analytics entry message

func (*AnalyticsEntryMessage) Descriptor

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

Deprecated: Use AnalyticsEntryMessage.ProtoReflect.Descriptor instead.

func (*AnalyticsEntryMessage) GetMethod

func (x *AnalyticsEntryMessage) GetMethod() string

func (*AnalyticsEntryMessage) GetService

func (x *AnalyticsEntryMessage) GetService() string

func (*AnalyticsEntryMessage) GetTransport

func (x *AnalyticsEntryMessage) GetTransport() string

func (*AnalyticsEntryMessage) ProtoMessage

func (*AnalyticsEntryMessage) ProtoMessage()

func (*AnalyticsEntryMessage) ProtoReflect

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

func (*AnalyticsEntryMessage) Reset

func (x *AnalyticsEntryMessage) Reset()

func (*AnalyticsEntryMessage) String

func (x *AnalyticsEntryMessage) String() string

type AnalyticsServer

type AnalyticsServer interface {
	// Connect a client
	LogData(context.Context, *LogDataRequest) (*emptypb.Empty, error)
	// Get a log
	GetLog(context.Context, *emptypb.Empty) (*GetLogsMessage, error)
	// contains filtered or unexported methods
}

AnalyticsServer is the server API for Analytics service. All implementations must embed UnimplementedAnalyticsServer for forward compatibility

type GetLogsMessage

type GetLogsMessage struct {
	Logs []*AnalyticsEntryMessage `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogsMessage) Descriptor

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

Deprecated: Use GetLogsMessage.ProtoReflect.Descriptor instead.

func (*GetLogsMessage) GetLogs

func (x *GetLogsMessage) GetLogs() []*AnalyticsEntryMessage

func (*GetLogsMessage) ProtoMessage

func (*GetLogsMessage) ProtoMessage()

func (*GetLogsMessage) ProtoReflect

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

func (*GetLogsMessage) Reset

func (x *GetLogsMessage) Reset()

func (*GetLogsMessage) String

func (x *GetLogsMessage) String() string

type LogDataRequest

type LogDataRequest struct {
	Transport string `protobuf:"bytes,1,opt,name=transport,proto3" json:"transport,omitempty"`
	Service   string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	Method    string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

Log data request

func (*LogDataRequest) Descriptor

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

Deprecated: Use LogDataRequest.ProtoReflect.Descriptor instead.

func (*LogDataRequest) GetMethod

func (x *LogDataRequest) GetMethod() string

func (*LogDataRequest) GetService

func (x *LogDataRequest) GetService() string

func (*LogDataRequest) GetTransport

func (x *LogDataRequest) GetTransport() string

func (*LogDataRequest) ProtoMessage

func (*LogDataRequest) ProtoMessage()

func (*LogDataRequest) ProtoReflect

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

func (*LogDataRequest) Reset

func (x *LogDataRequest) Reset()

func (*LogDataRequest) String

func (x *LogDataRequest) String() string

type UnimplementedAnalyticsServer

type UnimplementedAnalyticsServer struct {
}

UnimplementedAnalyticsServer must be embedded to have forward compatible implementations.

func (UnimplementedAnalyticsServer) GetLog

func (UnimplementedAnalyticsServer) GetLog(context.Context, *emptypb.Empty) (*GetLogsMessage, error)

func (UnimplementedAnalyticsServer) LogData

func (UnimplementedAnalyticsServer) LogData(context.Context, *LogDataRequest) (*emptypb.Empty, error)

type UnsafeAnalyticsServer

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

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