definition

type Event struct {

	// Type of the Event
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Creation Timestamp of the events. Defaults to the current timestamp
	Created *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created,proto3,oneof" json:"created,omitempty"`
	// Service ID of the Event
	ServiceId string `protobuf:"bytes,3,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// Event Dimensions
	Dimensions map[string]string `` /* 161-byte string literal not displayed */
	// Event Body values
	Body map[string]float32 `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EventsV1Client interface {
	// Sends events to the server once the stream is closed
	Emit(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[EventsV1Request, EventsV1Response], error)
}

type EventsV1Request struct {

	// List of the Events to produce as batch
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type EventsV1Response struct {

	// Number of the processed Events
	Processed int32 `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty"`
	// Defines if production was sync or async
	Completed bool `protobuf:"varint,2,opt,name=completed,proto3" json:"completed,omitempty"`
	// Creation Timestamp of the events. Defaults to the current timestamp
	Created *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created,proto3,oneof" json:"created,omitempty"`
	// contains filtered or unexported fields
}

type EventsV1Server interface {
	// Sends events to the server once the stream is closed
	Emit(grpc.ClientStreamingServer[EventsV1Request, EventsV1Response]) error
	// contains filtered or unexported methods
}

type EventsV1_EmitClient = grpc.ClientStreamingClient[EventsV1Request, EventsV1Response]

type EventsV1_EmitServer = grpc.ClientStreamingServer[EventsV1Request, EventsV1Response]

type UnimplementedEventsV1Server struct{}

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