protopb

type FxStovepipeOrchestratorYARPCClientParams ¶

type FxStovepipeOrchestratorYARPCClientParams struct {
	fx.In

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

FxStovepipeOrchestratorYARPCClientParams defines the input for NewFxStovepipeOrchestratorYARPCClient. It provides the paramaters to get a StovepipeOrchestratorYARPCClient in an Fx application.

type FxStovepipeOrchestratorYARPCClientResult ¶

type FxStovepipeOrchestratorYARPCClientResult struct {
	fx.Out

	Client StovepipeOrchestratorYARPCClient
}

FxStovepipeOrchestratorYARPCClientResult defines the output of NewFxStovepipeOrchestratorYARPCClient. It provides a StovepipeOrchestratorYARPCClient to an Fx application.

type FxStovepipeOrchestratorYARPCProceduresParams ¶

type FxStovepipeOrchestratorYARPCProceduresParams struct {
	fx.In

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

FxStovepipeOrchestratorYARPCProceduresParams defines the input for NewFxStovepipeOrchestratorYARPCProcedures. It provides the paramaters to get StovepipeOrchestratorYARPCServer procedures in an Fx application.

type FxStovepipeOrchestratorYARPCProceduresResult ¶

type FxStovepipeOrchestratorYARPCProceduresResult struct {
	fx.Out

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

FxStovepipeOrchestratorYARPCProceduresResult defines the output of NewFxStovepipeOrchestratorYARPCProcedures. It provides StovepipeOrchestratorYARPCServer 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 StovepipeOrchestratorClient ¶

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

StovepipeOrchestratorClient is the client API for StovepipeOrchestrator 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.

StovepipeOrchestrator provides the Stovepipe orchestrator API.

func NewStovepipeOrchestratorClient(cc grpc.ClientConnInterface) StovepipeOrchestratorClient

type StovepipeOrchestratorServer ¶

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

StovepipeOrchestratorServer is the server API for StovepipeOrchestrator service. All implementations must embed UnimplementedStovepipeOrchestratorServer for forward compatibility.

StovepipeOrchestrator provides the Stovepipe orchestrator API.

type StovepipeOrchestratorYARPCClient ¶

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

StovepipeOrchestratorYARPCClient is the YARPC client-side interface for the StovepipeOrchestrator service.

func NewStovepipeOrchestratorYARPCClient(clientConfig transport.ClientConfig, options ...v2.ClientOption) StovepipeOrchestratorYARPCClient

type StovepipeOrchestratorYARPCServer ¶

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

StovepipeOrchestratorYARPCServer is the YARPC server-side interface for the StovepipeOrchestrator service.

type UnimplementedStovepipeOrchestratorServer ¶

type UnimplementedStovepipeOrchestratorServer struct{}

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

type UnsafeStovepipeOrchestratorServer ¶

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

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