protopb

type FxSubmitQueueStovepipeYARPCClientParams ¶

type FxSubmitQueueStovepipeYARPCClientParams struct {
	fx.In

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

FxSubmitQueueStovepipeYARPCClientParams defines the input for NewFxSubmitQueueStovepipeYARPCClient. It provides the paramaters to get a SubmitQueueStovepipeYARPCClient in an Fx application.

type FxSubmitQueueStovepipeYARPCClientResult ¶

type FxSubmitQueueStovepipeYARPCClientResult struct {
	fx.Out

	Client SubmitQueueStovepipeYARPCClient
}

FxSubmitQueueStovepipeYARPCClientResult defines the output of NewFxSubmitQueueStovepipeYARPCClient. It provides a SubmitQueueStovepipeYARPCClient to an Fx application.

type FxSubmitQueueStovepipeYARPCProceduresParams ¶

type FxSubmitQueueStovepipeYARPCProceduresParams struct {
	fx.In

	Server      SubmitQueueStovepipeYARPCServer
	AnyResolver jsonpb.AnyResolver `name:"yarpcfx" optional:"true"`
}

FxSubmitQueueStovepipeYARPCProceduresParams defines the input for NewFxSubmitQueueStovepipeYARPCProcedures. It provides the paramaters to get SubmitQueueStovepipeYARPCServer procedures in an Fx application.

type FxSubmitQueueStovepipeYARPCProceduresResult ¶

type FxSubmitQueueStovepipeYARPCProceduresResult struct {
	fx.Out

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

FxSubmitQueueStovepipeYARPCProceduresResult defines the output of NewFxSubmitQueueStovepipeYARPCProcedures. It provides SubmitQueueStovepipeYARPCServer 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 SubmitQueueStovepipeClient ¶

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

SubmitQueueStovepipeClient is the client API for SubmitQueueStovepipe 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.

SubmitQueueStovepipe provides the stovepipe API

func NewSubmitQueueStovepipeClient(cc grpc.ClientConnInterface) SubmitQueueStovepipeClient

type SubmitQueueStovepipeServer ¶

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

SubmitQueueStovepipeServer is the server API for SubmitQueueStovepipe service. All implementations must embed UnimplementedSubmitQueueStovepipeServer for forward compatibility.

SubmitQueueStovepipe provides the stovepipe API

type SubmitQueueStovepipeYARPCClient ¶

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

SubmitQueueStovepipeYARPCClient is the YARPC client-side interface for the SubmitQueueStovepipe service.

func NewSubmitQueueStovepipeYARPCClient(clientConfig transport.ClientConfig, options ...protobuf.ClientOption) SubmitQueueStovepipeYARPCClient

type SubmitQueueStovepipeYARPCServer ¶

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

SubmitQueueStovepipeYARPCServer is the YARPC server-side interface for the SubmitQueueStovepipe service.

type UnimplementedSubmitQueueStovepipeServer ¶

type UnimplementedSubmitQueueStovepipeServer struct{}

UnimplementedSubmitQueueStovepipeServer 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 (UnimplementedSubmitQueueStovepipeServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

type UnsafeSubmitQueueStovepipeServer ¶

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

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