ingestion

Documentation

Index

• func RegisterIngestionServiceServer(s *grpc.Server, srv IngestionServiceServer)
• type EventRequest
  • func (*EventRequest) Descriptor() ([]byte, []int)
  • func (m *EventRequest) GetCreationDate() *timestamp.Timestamp
  • func (m *EventRequest) GetData() *_struct.Struct
  • func (m *EventRequest) GetType() string
  • func (*EventRequest) ProtoMessage()
  • 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
  • func (*EventsRequest) Descriptor() ([]byte, []int)
  • func (m *EventsRequest) GetEvents() []*EventRequest
  • func (m *EventsRequest) GetOrb() string
  • func (*EventsRequest) ProtoMessage()
  • 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
  • func NewIngestionServiceClient(cc grpc.ClientConnInterface) IngestionServiceClient
• type IngestionServiceServer
• type UnimplementedIngestionServiceServer
  • 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)

Functions

func RegisterIngestionServiceServer

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

Types

type EventRequest

type EventRequest struct {
	CreationDate         *timestamp.Timestamp `protobuf:"bytes,1,opt,name=creation_date,json=creationDate,proto3" json:"creation_date,omitempty"`
	Data                 *_struct.Struct      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Type                 string               `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*EventRequest) Descriptor

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

func (*EventRequest) GetCreationDate

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

func (*EventRequest) GetData

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

func (*EventRequest) GetType

func (m *EventRequest) GetType() string

func (*EventRequest) ProtoMessage

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset

func (m *EventRequest) Reset()

func (*EventRequest) String

func (m *EventRequest) String() string

func (*EventRequest) XXX_DiscardUnknown

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal

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

func (*EventRequest) XXX_Merge

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

func (*EventRequest) XXX_Size

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal

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

type EventsRequest

type EventsRequest struct {
	Orb                  string          `protobuf:"bytes,1,opt,name=orb,proto3" json:"orb,omitempty"`
	Events               []*EventRequest `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*EventsRequest) Descriptor

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

func (*EventsRequest) GetEvents

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

func (*EventsRequest) GetOrb

func (m *EventsRequest) GetOrb() string

func (*EventsRequest) ProtoMessage

func (*EventsRequest) ProtoMessage()

func (*EventsRequest) Reset

func (m *EventsRequest) Reset()

func (*EventsRequest) String

func (m *EventsRequest) String() string

func (*EventsRequest) XXX_DiscardUnknown

func (m *EventsRequest) XXX_DiscardUnknown()

func (*EventsRequest) XXX_Marshal

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

func (*EventsRequest) XXX_Merge

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

func (*EventsRequest) XXX_Size

func (m *EventsRequest) XXX_Size() int

func (*EventsRequest) XXX_Unmarshal

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

type IngestionServiceClient

type IngestionServiceClient interface {
	// Healthz returns status OK as soon as the service started
	Healthz(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// Ready returns status OK as soon as all dependent services are available
	Ready(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	PushEvents(ctx context.Context, in *EventsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

IngestionServiceClient is the client API for IngestionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIngestionServiceClient

func NewIngestionServiceClient(cc grpc.ClientConnInterface) IngestionServiceClient

type IngestionServiceServer

type IngestionServiceServer interface {
	// Healthz returns status OK as soon as the service started
	Healthz(context.Context, *empty.Empty) (*empty.Empty, error)
	// Ready returns status OK as soon as all dependent services are available
	Ready(context.Context, *empty.Empty) (*empty.Empty, error)
	PushEvents(context.Context, *EventsRequest) (*empty.Empty, error)
}

IngestionServiceServer is the server API for IngestionService service.

type UnimplementedIngestionServiceServer

type UnimplementedIngestionServiceServer struct {
}

UnimplementedIngestionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIngestionServiceServer) Healthz

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

func (*UnimplementedIngestionServiceServer) PushEvents

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

func (*UnimplementedIngestionServiceServer) Ready

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