contracts

type BulkPushEventRequest struct {
	Events []*PushEventRequest `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type Event struct {

	// the tenant id
	TenantId string `protobuf:"bytes,1,opt,name=tenantId,proto3" json:"tenantId,omitempty"`
	// the id of the event
	EventId string `protobuf:"bytes,2,opt,name=eventId,proto3" json:"eventId,omitempty"`
	// the key for the event
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// the payload for the event
	Payload string `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// when the event was generated
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"`
	// the additional metadata for the event
	AdditionalMetadata *string `protobuf:"bytes,6,opt,name=additionalMetadata,proto3,oneof" json:"additionalMetadata,omitempty"`
	// the scope associated with this filter. Used for subsetting candidate filters at evaluation time
	Scope *string `protobuf:"bytes,7,opt,name=scope,proto3,oneof" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

type Events struct {
	Events []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type EventsServiceClient interface {
	Push(ctx context.Context, in *PushEventRequest, opts ...grpc.CallOption) (*Event, error)
	BulkPush(ctx context.Context, in *BulkPushEventRequest, opts ...grpc.CallOption) (*Events, error)
	ReplaySingleEvent(ctx context.Context, in *ReplayEventRequest, opts ...grpc.CallOption) (*Event, error)
	PutLog(ctx context.Context, in *PutLogRequest, opts ...grpc.CallOption) (*PutLogResponse, error)
	PutStreamEvent(ctx context.Context, in *PutStreamEventRequest, opts ...grpc.CallOption) (*PutStreamEventResponse, error)
}

type EventsServiceServer interface {
	Push(context.Context, *PushEventRequest) (*Event, error)
	BulkPush(context.Context, *BulkPushEventRequest) (*Events, error)
	ReplaySingleEvent(context.Context, *ReplayEventRequest) (*Event, error)
	PutLog(context.Context, *PutLogRequest) (*PutLogResponse, error)
	PutStreamEvent(context.Context, *PutStreamEventRequest) (*PutStreamEventResponse, error)
	// contains filtered or unexported methods
}

type PushEventRequest struct {

	// the key for the event
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// the payload for the event
	Payload string `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// when the event was generated
	EventTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=eventTimestamp,proto3" json:"eventTimestamp,omitempty"`
	// metadata for the event
	AdditionalMetadata *string `protobuf:"bytes,4,opt,name=additionalMetadata,proto3,oneof" json:"additionalMetadata,omitempty"`
	Priority           *int32  `protobuf:"varint,5,opt,name=priority,proto3,oneof" json:"priority,omitempty"`
	// the scope associated with this filter. Used for subsetting candidate filters at evaluation time
	Scope *string `protobuf:"bytes,6,opt,name=scope,proto3,oneof" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

type PutLogRequest struct {

	// the step run id for the request
	StepRunId string `protobuf:"bytes,1,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	// when the log line was created
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	// the log line message
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// the log line level
	Level *string `protobuf:"bytes,4,opt,name=level,proto3,oneof" json:"level,omitempty"`
	// associated log line metadata
	Metadata string `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// the retry count of the task run
	TaskRetryCount *int32 `protobuf:"varint,6,opt,name=taskRetryCount,proto3,oneof" json:"taskRetryCount,omitempty"`
	// contains filtered or unexported fields
}

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

type PutStreamEventRequest struct {

	// the step run id for the request
	StepRunId string `protobuf:"bytes,1,opt,name=stepRunId,proto3" json:"stepRunId,omitempty"`
	// when the stream event was created
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	// the stream event message
	Message []byte `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// associated stream event metadata
	Metadata   string `protobuf:"bytes,5,opt,name=metadata,proto3" json:"metadata,omitempty"`
	EventIndex *int64 `protobuf:"varint,6,opt,name=eventIndex,proto3,oneof" json:"eventIndex,omitempty"`
	// contains filtered or unexported fields
}

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

type ReplayEventRequest struct {

	// the event id to replay
	EventId string `protobuf:"bytes,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventsServiceServer struct {
}

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