eventstreamapi

type Event struct {
	Event *pb.CloudEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type EventStreamClient interface {
	Subscribe(ctx context.Context, opts ...grpc.CallOption) (EventStream_SubscribeClient, error)
	Push(ctx context.Context, opts ...grpc.CallOption) (EventStream_PushClient, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PongReply, error)
}

type EventStreamServer interface {
	Subscribe(EventStream_SubscribeServer) error
	Push(EventStream_PushServer) error
	Ping(context.Context, *PingRequest) (*PongReply, error)
	// contains filtered or unexported methods
}

type EventStream_PushClient interface {
	Send(*Event) error
	CloseAndRecv() (*PushSummary, error)
	grpc.ClientStream
}

type EventStream_PushServer interface {
	SendAndClose(*PushSummary) error
	Recv() (*Event, error)
	grpc.ServerStream
}

type EventStream_SubscribeClient interface {
	Send(*Event) error
	Recv() (*Event, error)
	grpc.ClientStream
}

type EventStream_SubscribeServer interface {
	Send(*Event) error
	Recv() (*Event, error)
	grpc.ServerStream
}

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

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

type PushSummary struct {
	Result    string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	Received  int32  `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	Processed int32  `protobuf:"varint,3,opt,name=processed,proto3" json:"processed,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventStreamServer struct {
}

type UnsafeEventStreamServer interface {
	// contains filtered or unexported methods
}