Documentation ¶
Index ¶
- Variables
- func New(ctx context.Context, client *pubsub.Client, topic *pubsub.Topic, ...) *eventSinkServer
- func RegisterEventSinkServer(s *grpc.Server, srv EventSinkServer)
- type CanonicalEvent
- func (*CanonicalEvent) Descriptor() ([]byte, []int)deprecated
- func (x *CanonicalEvent) GetCreatedAt() string
- func (x *CanonicalEvent) GetEventId() string
- func (x *CanonicalEvent) GetMetadata() string
- func (x *CanonicalEvent) GetMethod() string
- func (x *CanonicalEvent) GetOrgId() string
- func (x *CanonicalEvent) GetOs() string
- func (x *CanonicalEvent) GetProjectId() string
- func (x *CanonicalEvent) GetTrackerVersion() string
- func (x *CanonicalEvent) GetUserId() string
- func (x *CanonicalEvent) GetVerb() string
- func (x *CanonicalEvent) GetVersion() string
- func (*CanonicalEvent) ProtoMessage()
- func (x *CanonicalEvent) ProtoReflect() protoreflect.Message
- func (x *CanonicalEvent) Reset()
- func (x *CanonicalEvent) Save() (map[string]bigquery.Value, string, error)
- func (x *CanonicalEvent) String() string
- type EventSinkClient
- type EventSinkServer
- type RecordCanonicalEventResponse
- func (*RecordCanonicalEventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RecordCanonicalEventResponse) GetOk() bool
- func (*RecordCanonicalEventResponse) ProtoMessage()
- func (x *RecordCanonicalEventResponse) ProtoReflect() protoreflect.Message
- func (x *RecordCanonicalEventResponse) Reset()
- func (x *RecordCanonicalEventResponse) String() string
- type UnimplementedEventSinkServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_event_sink_server_proto protoreflect.FileDescriptor
Functions ¶
func New ¶
func New(ctx context.Context, client *pubsub.Client, topic *pubsub.Topic, subscription *pubsub.Subscription) *eventSinkServer
New creates a new event sink server
func RegisterEventSinkServer ¶
func RegisterEventSinkServer(s *grpc.Server, srv EventSinkServer)
Types ¶
type CanonicalEvent ¶
type CanonicalEvent struct { OrgId string `protobuf:"bytes,1,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"` ProjectId string `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"` EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"` UserId string `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"` Verb string `protobuf:"bytes,5,opt,name=verb,proto3" json:"verb,omitempty"` Method string `protobuf:"bytes,6,opt,name=method,proto3" json:"method,omitempty"` Os string `protobuf:"bytes,7,opt,name=os,proto3" json:"os,omitempty"` Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"` TrackerVersion string `protobuf:"bytes,9,opt,name=tracker_version,json=trackerVersion,proto3" json:"tracker_version,omitempty"` Metadata string `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"` CreatedAt string `protobuf:"bytes,11,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` // contains filtered or unexported fields }
func (*CanonicalEvent) Descriptor
deprecated
func (*CanonicalEvent) Descriptor() ([]byte, []int)
Deprecated: Use CanonicalEvent.ProtoReflect.Descriptor instead.
func (*CanonicalEvent) GetCreatedAt ¶
func (x *CanonicalEvent) GetCreatedAt() string
func (*CanonicalEvent) GetEventId ¶
func (x *CanonicalEvent) GetEventId() string
func (*CanonicalEvent) GetMetadata ¶
func (x *CanonicalEvent) GetMetadata() string
func (*CanonicalEvent) GetMethod ¶
func (x *CanonicalEvent) GetMethod() string
func (*CanonicalEvent) GetOrgId ¶
func (x *CanonicalEvent) GetOrgId() string
func (*CanonicalEvent) GetOs ¶
func (x *CanonicalEvent) GetOs() string
func (*CanonicalEvent) GetProjectId ¶
func (x *CanonicalEvent) GetProjectId() string
func (*CanonicalEvent) GetTrackerVersion ¶
func (x *CanonicalEvent) GetTrackerVersion() string
func (*CanonicalEvent) GetUserId ¶
func (x *CanonicalEvent) GetUserId() string
func (*CanonicalEvent) GetVerb ¶
func (x *CanonicalEvent) GetVerb() string
func (*CanonicalEvent) GetVersion ¶
func (x *CanonicalEvent) GetVersion() string
func (*CanonicalEvent) ProtoMessage ¶
func (*CanonicalEvent) ProtoMessage()
func (*CanonicalEvent) ProtoReflect ¶
func (x *CanonicalEvent) ProtoReflect() protoreflect.Message
func (*CanonicalEvent) Reset ¶
func (x *CanonicalEvent) Reset()
func (*CanonicalEvent) Save ¶
Save implements the ValueSaver interface for inserting data into BigQuery tables
func (*CanonicalEvent) String ¶
func (x *CanonicalEvent) String() string
type EventSinkClient ¶
type EventSinkClient interface {
RecordCanonicalEvent(ctx context.Context, in *CanonicalEvent, opts ...grpc.CallOption) (*RecordCanonicalEventResponse, error)
}
EventSinkClient is the client API for EventSink service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewEventSinkClient ¶
func NewEventSinkClient(cc grpc.ClientConnInterface) EventSinkClient
type EventSinkServer ¶
type EventSinkServer interface {
RecordCanonicalEvent(context.Context, *CanonicalEvent) (*RecordCanonicalEventResponse, error)
}
EventSinkServer is the server API for EventSink service.
type RecordCanonicalEventResponse ¶
type RecordCanonicalEventResponse struct { Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"` // contains filtered or unexported fields }
func (*RecordCanonicalEventResponse) Descriptor
deprecated
func (*RecordCanonicalEventResponse) Descriptor() ([]byte, []int)
Deprecated: Use RecordCanonicalEventResponse.ProtoReflect.Descriptor instead.
func (*RecordCanonicalEventResponse) GetOk ¶
func (x *RecordCanonicalEventResponse) GetOk() bool
func (*RecordCanonicalEventResponse) ProtoMessage ¶
func (*RecordCanonicalEventResponse) ProtoMessage()
func (*RecordCanonicalEventResponse) ProtoReflect ¶
func (x *RecordCanonicalEventResponse) ProtoReflect() protoreflect.Message
func (*RecordCanonicalEventResponse) Reset ¶
func (x *RecordCanonicalEventResponse) Reset()
func (*RecordCanonicalEventResponse) String ¶
func (x *RecordCanonicalEventResponse) String() string
type UnimplementedEventSinkServer ¶
type UnimplementedEventSinkServer struct { }
UnimplementedEventSinkServer can be embedded to have forward compatible implementations.
func (*UnimplementedEventSinkServer) RecordCanonicalEvent ¶
func (*UnimplementedEventSinkServer) RecordCanonicalEvent(context.Context, *CanonicalEvent) (*RecordCanonicalEventResponse, error)
Click to show internal directories.
Click to hide internal directories.