protopb

type FxStovepipeYARPCClientParams struct {
	fx.In

	Provider    yarpc.ClientConfig
	AnyResolver v2.AnyResolver      `name:"yarpcfx" optional:"true"`
	Restriction restriction.Checker `optional:"true"`
}

type FxStovepipeYARPCClientResult struct {
	fx.Out

	Client StovepipeYARPCClient
}

type FxStovepipeYARPCProceduresParams struct {
	fx.In

	Server      StovepipeYARPCServer
	AnyResolver v2.AnyResolver `name:"yarpcfx" optional:"true"`
}

type FxStovepipeYARPCProceduresResult struct {
	fx.Out

	Procedures     []transport.Procedure `group:"yarpcfx"`
	ReflectionMeta reflection.ServerMeta `group:"yarpcfx"`
}

type IngestRequest struct {

	// Logical queue name to validate (e.g. "monorepo/main"). It namespaces the minted
	// request ID and is the stable handle for the repo+ref being validated.
	Queue string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

type IngestResponse struct {

	// The minted request ID, namespaced by queue. Format: "request/<queue>/<counter>"
	// (e.g. "request/monorepo/main/42").
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type PingRequest struct {

	// Optional message to include in the ping
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type PingResponse struct {

	// The response message
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// The service name that handled the request
	ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// Timestamp of when the ping was received
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Hostname of the server that handled the request
	Hostname string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

type StovepipeClient interface {
	// Ping returns a response indicating the service is alive
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Ingest admits a queue's newly observed commit into the validation pipeline and returns
	// the minted request ID. The caller hands off asynchronously; validation happens later.
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
}

type StovepipeServer interface {
	// Ping returns a response indicating the service is alive
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Ingest admits a queue's newly observed commit into the validation pipeline and returns
	// the minted request ID. The caller hands off asynchronously; validation happens later.
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
	// contains filtered or unexported methods
}

type StovepipeYARPCClient interface {
	Ping(context.Context, *PingRequest, ...yarpc.CallOption) (*PingResponse, error)
	Ingest(context.Context, *IngestRequest, ...yarpc.CallOption) (*IngestResponse, error)
}

type StovepipeYARPCServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
}

type UnimplementedStovepipeServer struct{}

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