analytics

package
v1.19.1 Latest Latest
Warning

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

 Go to latest Published: Mar 1, 2024 License: MPL-2.0 Imports: 8 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Analytics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloudquery.backend.analytics.Analytics",
	HandlerType: (*AnalyticsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendEvent",
			Handler:    _Analytics_SendEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/pb/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)

View Source 
var File_internal_pb_analytics_proto protoreflect.FileDescriptor

Functions

func RegisterAnalyticsServer 

func RegisterAnalyticsServer(s grpc.ServiceRegistrar, srv AnalyticsServer)

Types

type AnalyticsClient 

type AnalyticsClient interface {
	SendEvent(ctx context.Context, in *Event_Request, opts ...grpc.CallOption) (*Event_Response, 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 AnalyticsServer 

type AnalyticsServer interface {
	SendEvent(context.Context, *Event_Request) (*Event_Response, error)
	// contains filtered or unexported methods
}

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

type Destination 

type Destination struct {
	Path    string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`       // path of destination plugin; registry is assumed to be Github
	Version string `protobuf:"bytes,2,opt,name=Version,proto3" json:"Version,omitempty"` // version of destination plugin used
	// contains filtered or unexported fields
}

func (*Destination) Descriptor deprecated 

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

Deprecated: Use Destination.ProtoReflect.Descriptor instead.

func (*Destination) GetPath 

func (x *Destination) GetPath() string

func (*Destination) GetVersion 

func (x *Destination) GetVersion() string

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) ProtoReflect 

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

func (*Destination) Reset 

func (x *Destination) Reset()

func (*Destination) String 

func (x *Destination) String() string

type Event 

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

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_Request 

type Event_Request struct {
	SyncSummary *SyncSummary `protobuf:"bytes,1,opt,name=sync_summary,json=syncSummary,proto3" json:"sync_summary,omitempty"`
	// contains filtered or unexported fields
}

func (*Event_Request) Descriptor deprecated 

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

Deprecated: Use Event_Request.ProtoReflect.Descriptor instead.

func (*Event_Request) GetSyncSummary 

func (x *Event_Request) GetSyncSummary() *SyncSummary

func (*Event_Request) ProtoMessage 

func (*Event_Request) ProtoMessage()

func (*Event_Request) ProtoReflect 

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

func (*Event_Request) Reset 

func (x *Event_Request) Reset()

func (*Event_Request) String 

func (x *Event_Request) String() string

type Event_Response 

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

func (*Event_Response) Descriptor deprecated 

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

Deprecated: Use Event_Response.ProtoReflect.Descriptor instead.

func (*Event_Response) ProtoMessage 

func (*Event_Response) ProtoMessage()

func (*Event_Response) ProtoReflect 

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

func (*Event_Response) Reset 

func (x *Event_Response) Reset()

func (*Event_Response) String 

func (x *Event_Response) String() string

type SyncSummary 

type SyncSummary struct {
	Invocation_UUID string         `protobuf:"bytes,1,opt,name=Invocation_UUID,json=InvocationUUID,proto3" json:"Invocation_UUID,omitempty"` // unique ID for each CLI invocation (This could be the same for some rows if multiple sources or destinations are being synced)
	Message_UUID    string         `protobuf:"bytes,2,opt,name=Message_UUID,json=MessageUUID,proto3" json:"Message_UUID,omitempty"`          // server-side UUID to uniquely identify every message and do at-least-once write
	Timestamp       int64          `protobuf:"varint,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`                                // server-side timestamp for when message was received
	SourcePath      string         `protobuf:"bytes,4,opt,name=Source_path,json=SourcePath,proto3" json:"Source_path,omitempty"`             // path of source plugin; registry is assumed to be Github
	SourceVersion   string         `protobuf:"bytes,5,opt,name=Source_version,json=SourceVersion,proto3" json:"Source_version,omitempty"`    // version of source plugin used
	Destinations    []*Destination `protobuf:"bytes,6,rep,name=Destinations,proto3" json:"Destinations,omitempty"`
	Resources       int64          `protobuf:"varint,8,opt,name=Resources,proto3" json:"Resources,omitempty"`                              // number of resources fetched
	Errors          int64          `protobuf:"varint,9,opt,name=Errors,proto3" json:"Errors,omitempty"`                                    // number of errors that occurred
	Panics          int64          `protobuf:"varint,10,opt,name=Panics,proto3" json:"Panics,omitempty"`                                   // number of panics that occurred
	ClientVersion   string         `protobuf:"bytes,11,opt,name=Client_version,json=ClientVersion,proto3" json:"Client_version,omitempty"` // client (CLI) version used
	ExitReason      string         `protobuf:"bytes,12,opt,name=Exit_reason,json=ExitReason,proto3" json:"Exit_reason,omitempty"`          // reason for early exit, if any
	// contains filtered or unexported fields
}

func (*SyncSummary) Descriptor deprecated 

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

Deprecated: Use SyncSummary.ProtoReflect.Descriptor instead.

func (*SyncSummary) GetClientVersion 

func (x *SyncSummary) GetClientVersion() string

func (*SyncSummary) GetDestinations 

func (x *SyncSummary) GetDestinations() []*Destination

func (*SyncSummary) GetErrors 

func (x *SyncSummary) GetErrors() int64

func (*SyncSummary) GetExitReason 

func (x *SyncSummary) GetExitReason() string

func (*SyncSummary) GetInvocation_UUID 

func (x *SyncSummary) GetInvocation_UUID() string

func (*SyncSummary) GetMessage_UUID 

func (x *SyncSummary) GetMessage_UUID() string

func (*SyncSummary) GetPanics 

func (x *SyncSummary) GetPanics() int64

func (*SyncSummary) GetResources 

func (x *SyncSummary) GetResources() int64

func (*SyncSummary) GetSourcePath 

func (x *SyncSummary) GetSourcePath() string

func (*SyncSummary) GetSourceVersion 

func (x *SyncSummary) GetSourceVersion() string

func (*SyncSummary) GetTimestamp 

func (x *SyncSummary) GetTimestamp() int64

func (*SyncSummary) ProtoMessage 

func (*SyncSummary) ProtoMessage()

func (*SyncSummary) ProtoReflect 

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

func (*SyncSummary) Reset 

func (x *SyncSummary) Reset()

func (*SyncSummary) String 

func (x *SyncSummary) String() string

type UnimplementedAnalyticsServer 

type UnimplementedAnalyticsServer struct {
}

UnimplementedAnalyticsServer must be embedded to have forward compatible implementations.

func (UnimplementedAnalyticsServer) SendEvent 

func (UnimplementedAnalyticsServer) SendEvent(context.Context, *Event_Request) (*Event_Response, 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.

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.