ingestion

Mar 25, 2020

Changes in this version

+ func RegisterIngestionServiceServer(s *grpc.Server, srv IngestionServiceServer)

+ type EventRequest struct

+ CreationDate *timestamp.Timestamp

+ Data *_struct.Struct

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EventRequest) Descriptor() ([]byte, []int)

+ func (*EventRequest) ProtoMessage()

+ func (m *EventRequest) GetCreationDate() *timestamp.Timestamp

+ func (m *EventRequest) GetData() *_struct.Struct

+ func (m *EventRequest) GetType() string

+ func (m *EventRequest) Reset()

+ func (m *EventRequest) String() string

+ func (m *EventRequest) XXX_DiscardUnknown()

+ func (m *EventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventRequest) XXX_Merge(src proto.Message)

+ func (m *EventRequest) XXX_Size() int

+ func (m *EventRequest) XXX_Unmarshal(b []byte) error

+ type EventsRequest struct

+ Events []*EventRequest

+ Orb string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EventsRequest) Descriptor() ([]byte, []int)

+ func (*EventsRequest) ProtoMessage()

+ func (m *EventsRequest) GetEvents() []*EventRequest

+ func (m *EventsRequest) GetOrb() string

+ func (m *EventsRequest) Reset()

+ func (m *EventsRequest) String() string

+ func (m *EventsRequest) XXX_DiscardUnknown()

+ func (m *EventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventsRequest) XXX_Merge(src proto.Message)

+ func (m *EventsRequest) XXX_Size() int

+ func (m *EventsRequest) XXX_Unmarshal(b []byte) error

+ type IngestionServiceClient interface

+ Healthz func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)

+ PushEvents func(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (*empty.Empty, error)

+ Ready func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)

+ func NewIngestionServiceClient(cc grpc.ClientConnInterface) IngestionServiceClient

+ type IngestionServiceServer interface

+ Healthz func(context.Context, *empty.Empty) (*empty.Empty, error)

+ PushEvents func(context.Context, *EventsRequest) (*empty.Empty, error)

+ Ready func(context.Context, *empty.Empty) (*empty.Empty, error)

+ type UnimplementedIngestionServiceServer struct

+ func (*UnimplementedIngestionServiceServer) Healthz(ctx context.Context, req *empty.Empty) (*empty.Empty, error)

+ func (*UnimplementedIngestionServiceServer) PushEvents(ctx context.Context, req *EventsRequest) (*empty.Empty, error)

+ func (*UnimplementedIngestionServiceServer) Ready(ctx context.Context, req *empty.Empty) (*empty.Empty, error)