protopb

type FxSubmitQueueOrchestratorYARPCClientParams ¶

type FxSubmitQueueOrchestratorYARPCClientParams struct {
	fx.In

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

FxSubmitQueueOrchestratorYARPCClientParams defines the input for NewFxSubmitQueueOrchestratorYARPCClient. It provides the paramaters to get a SubmitQueueOrchestratorYARPCClient in an Fx application.

type FxSubmitQueueOrchestratorYARPCClientResult ¶

type FxSubmitQueueOrchestratorYARPCClientResult struct {
	fx.Out

	Client SubmitQueueOrchestratorYARPCClient
}

FxSubmitQueueOrchestratorYARPCClientResult defines the output of NewFxSubmitQueueOrchestratorYARPCClient. It provides a SubmitQueueOrchestratorYARPCClient to an Fx application.

type FxSubmitQueueOrchestratorYARPCProceduresParams ¶

type FxSubmitQueueOrchestratorYARPCProceduresParams struct {
	fx.In

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

FxSubmitQueueOrchestratorYARPCProceduresParams defines the input for NewFxSubmitQueueOrchestratorYARPCProcedures. It provides the paramaters to get SubmitQueueOrchestratorYARPCServer procedures in an Fx application.

type FxSubmitQueueOrchestratorYARPCProceduresResult ¶

type FxSubmitQueueOrchestratorYARPCProceduresResult struct {
	fx.Out

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

FxSubmitQueueOrchestratorYARPCProceduresResult defines the output of NewFxSubmitQueueOrchestratorYARPCProcedures. It provides SubmitQueueOrchestratorYARPCServer procedures to an Fx application.

The procedures are provided to the "yarpcfx" value group. Dig 1.2 or newer must be used for this feature to work.

type PingRequest ¶

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
}

PingRequest is the request for the Ping method

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

func (x *PingRequest) GetMessage() string

func (*PingRequest) ProtoMessage()

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (x *PingRequest) Reset()

func (x *PingRequest) String() string

type PingResponse ¶

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
}

PingResponse is the response for the Ping method

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

func (x *PingResponse) GetHostname() string

func (x *PingResponse) GetMessage() string

func (x *PingResponse) GetServiceName() string

func (x *PingResponse) GetTimestamp() int64

func (*PingResponse) ProtoMessage()

func (x *PingResponse) ProtoReflect() protoreflect.Message

func (x *PingResponse) Reset()

func (x *PingResponse) String() string

type SubmitQueueOrchestratorClient ¶

type SubmitQueueOrchestratorClient interface {
	// Ping returns a response indicating the service is alive
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

SubmitQueueOrchestratorClient is the client API for SubmitQueueOrchestrator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

SubmitQueueOrchestrator provides the orchestrator API

func NewSubmitQueueOrchestratorClient(cc grpc.ClientConnInterface) SubmitQueueOrchestratorClient

type SubmitQueueOrchestratorServer ¶

type SubmitQueueOrchestratorServer interface {
	// Ping returns a response indicating the service is alive
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// contains filtered or unexported methods
}

SubmitQueueOrchestratorServer is the server API for SubmitQueueOrchestrator service. All implementations must embed UnimplementedSubmitQueueOrchestratorServer for forward compatibility.

SubmitQueueOrchestrator provides the orchestrator API

type SubmitQueueOrchestratorYARPCClient ¶

type SubmitQueueOrchestratorYARPCClient interface {
	Ping(context.Context, *PingRequest, ...yarpc.CallOption) (*PingResponse, error)
}

SubmitQueueOrchestratorYARPCClient is the YARPC client-side interface for the SubmitQueueOrchestrator service.

func NewSubmitQueueOrchestratorYARPCClient(clientConfig transport.ClientConfig, options ...v2.ClientOption) SubmitQueueOrchestratorYARPCClient

type SubmitQueueOrchestratorYARPCServer ¶

type SubmitQueueOrchestratorYARPCServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

SubmitQueueOrchestratorYARPCServer is the YARPC server-side interface for the SubmitQueueOrchestrator service.

type UnimplementedSubmitQueueOrchestratorServer ¶

type UnimplementedSubmitQueueOrchestratorServer struct{}

UnimplementedSubmitQueueOrchestratorServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSubmitQueueOrchestratorServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

type UnsafeSubmitQueueOrchestratorServer ¶

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

UnsafeSubmitQueueOrchestratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubmitQueueOrchestratorServer will result in compilation errors.