my_service

type Ignored struct {
	// contains filtered or unexported fields
}

type MyRequest struct {
	// contains filtered or unexported fields
}

type MyResponse struct {
	// contains filtered or unexported fields
}

type MyServiceClient interface {
	// A normal RPC - one request, one response. The request will be handled by the first available server
	NormalRPC(context.Context, *MyRequest, ...psrpc1.RequestOption) (*MyResponse, error)

	// An RPC with a server affinity function for handler selection.
	IntensiveRPC(context.Context, *MyRequest, ...psrpc1.RequestOption) (*MyResponse, error)

	// A multi-rpc - a client will send one request, and receive one response each from every server
	GetStats(context.Context, *MyRequest, ...psrpc1.RequestOption) (<-chan *psrpc1.Response[*MyResponse], error)

	// An RPC with topics - a client can send one request, and receive one response from each server in one region
	GetRegionStats(context.Context, string, *MyRequest, ...psrpc1.RequestOption) (<-chan *psrpc1.Response[*MyResponse], error)

	// A queue subscription - even if multiple clients are subscribed, only one will receive this update.
	// The request parameter (Ignored) will be ignored when generating go files.
	SubscribeProcessUpdate(context.Context) (psrpc1.Subscription[*MyUpdate], error)

	// A subscription with topics - every client subscribed to the topic will receive every update.
	// The request parameter (Ignored) will be ignored when generating go files.
	SubscribeUpdateRegionState(context.Context, string) (psrpc1.Subscription[*MyUpdate], error)
}

type MyServiceServer interface {
	// An RPC with topics - a client can send one request, and receive one response from each server in one region
	RegisterGetRegionStatsTopic(string) error
	DeregisterGetRegionStatsTopic(string)

	// A queue subscription - even if multiple clients are subscribed, only one will receive this update.
	// The request parameter (Ignored) will be ignored when generating go files.
	PublishProcessUpdate(context.Context, *MyUpdate) error

	// A subscription with topics - every client subscribed to the topic will receive every update.
	// The request parameter (Ignored) will be ignored when generating go files.
	PublishUpdateRegionState(context.Context, string, *MyUpdate) error

	// Close and wait for pending RPCs to complete
	Shutdown()

	// Close immediately, without waiting for pending RPCs
	Kill()
}

type MyServiceServerImpl interface {
	// A normal RPC - one request, one response. The request will be handled by the first available server
	NormalRPC(context.Context, *MyRequest) (*MyResponse, error)

	// An RPC with a server affinity function for handler selection.
	IntensiveRPC(context.Context, *MyRequest) (*MyResponse, error)
	IntensiveRPCAffinity(*MyRequest) float32

	// A multi-rpc - a client will send one request, and receive one response each from every server
	GetStats(context.Context, *MyRequest) (*MyResponse, error)

	// An RPC with topics - a client can send one request, and receive one response from each server in one region
	GetRegionStats(context.Context, *MyRequest) (*MyResponse, error)
}

type MyUpdate struct {
	// contains filtered or unexported fields
}