event_sink_server

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)
  • 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
  • func NewEventSinkClient(cc grpc.ClientConnInterface) EventSinkClient
• type EventSinkServer
• type RecordCanonicalEventResponse
  • func (*RecordCanonicalEventResponse) Descriptor() ([]byte, []int)
  • 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
  • func (*UnimplementedEventSinkServer) RecordCanonicalEvent(context.Context, *CanonicalEvent) (*RecordCanonicalEventResponse, error)

Variables

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

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

func (x *CanonicalEvent) Save() (map[string]bigquery.Value, string, error)

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

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)