protopb

type FxStovepipeGatewayYARPCClientParams ¶

type FxStovepipeGatewayYARPCClientParams struct {
	fx.In

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

FxStovepipeGatewayYARPCClientParams defines the input for NewFxStovepipeGatewayYARPCClient. It provides the paramaters to get a StovepipeGatewayYARPCClient in an Fx application.

type FxStovepipeGatewayYARPCClientResult ¶

type FxStovepipeGatewayYARPCClientResult struct {
	fx.Out

	Client StovepipeGatewayYARPCClient
}

FxStovepipeGatewayYARPCClientResult defines the output of NewFxStovepipeGatewayYARPCClient. It provides a StovepipeGatewayYARPCClient to an Fx application.

type FxStovepipeGatewayYARPCProceduresParams ¶

type FxStovepipeGatewayYARPCProceduresParams struct {
	fx.In

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

FxStovepipeGatewayYARPCProceduresParams defines the input for NewFxStovepipeGatewayYARPCProcedures. It provides the paramaters to get StovepipeGatewayYARPCServer procedures in an Fx application.

type FxStovepipeGatewayYARPCProceduresResult ¶

type FxStovepipeGatewayYARPCProceduresResult struct {
	fx.Out

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

FxStovepipeGatewayYARPCProceduresResult defines the output of NewFxStovepipeGatewayYARPCProcedures. It provides StovepipeGatewayYARPCServer 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 StovepipeGatewayClient ¶

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

StovepipeGatewayClient is the client API for StovepipeGateway 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.

StovepipeGateway provides the Stovepipe gateway API.

func NewStovepipeGatewayClient(cc grpc.ClientConnInterface) StovepipeGatewayClient

type StovepipeGatewayServer ¶

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

StovepipeGatewayServer is the server API for StovepipeGateway service. All implementations must embed UnimplementedStovepipeGatewayServer for forward compatibility.

StovepipeGateway provides the Stovepipe gateway API.

type StovepipeGatewayYARPCClient ¶

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

StovepipeGatewayYARPCClient is the YARPC client-side interface for the StovepipeGateway service.

func NewStovepipeGatewayYARPCClient(clientConfig transport.ClientConfig, options ...v2.ClientOption) StovepipeGatewayYARPCClient

type StovepipeGatewayYARPCServer ¶

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

StovepipeGatewayYARPCServer is the YARPC server-side interface for the StovepipeGateway service.

type UnimplementedStovepipeGatewayServer ¶

type UnimplementedStovepipeGatewayServer struct{}

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

type UnsafeStovepipeGatewayServer ¶

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

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