runtimev1connect

type EventServiceClient interface {
	// PushEvent pushes a given event to connect.runtime.v1.EventService service.
	PushEvent(context.Context, *connect_go.Request[v1.PushEventRequest]) (*connect_go.Response[v1.PushEventResponse], error)
}

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

type EventServiceController struct {
	// EventService contains an instance of cloud.runtime.v1.EventService service.
	EventService runtimev1.EventService
}

type EventServiceHandler interface {
	// PushEvent pushes a given event to connect.runtime.v1.EventService service.
	PushEvent(context.Context, *connect_go.Request[v1.PushEventRequest]) (*connect_go.Response[v1.PushEventResponse], error)
}

type HealthServiceClient interface {
	// If the requested service is unknown, the call will fail with status
	// NOT_FOUND.
	Check(context.Context, *connect_go.Request[v1.HealthCheckRequest]) (*connect_go.Response[v1.HealthCheckResponse], error)
	// Performs a watch for the serving status of the requested service.
	// The server will immediately send back a message indicating the current
	// serving status.  It will then subsequently send a new message whenever
	// the service's serving status changes.
	//
	// If the requested service is unknown when the call is received, the
	// server will send a message setting the serving status to
	// SERVICE_UNKNOWN but will *not* terminate the call.  If at some
	// future point, the serving status of the service becomes known, the
	// server will send a new message with the service's serving status.
	//
	// If the call terminates with status UNIMPLEMENTED, then clients
	// should assume this method is not supported and should not retry the
	// call.  If the call terminates with any other status (including OK),
	// clients should retry the call with appropriate exponential backoff.
	Watch(context.Context, *connect_go.Request[v1.HealthCheckRequest]) (*connect_go.ServerStreamForClient[v1.HealthCheckResponse], error)
}

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

type HealthServiceController struct {
	// HealthService contains an instance of cloud.runtime.v1.HealthService service.
	HealthService runtimev1.HealthService
}

type HealthServiceHandler interface {
	// If the requested service is unknown, the call will fail with status
	// NOT_FOUND.
	Check(context.Context, *connect_go.Request[v1.HealthCheckRequest]) (*connect_go.Response[v1.HealthCheckResponse], error)
	// Performs a watch for the serving status of the requested service.
	// The server will immediately send back a message indicating the current
	// serving status.  It will then subsequently send a new message whenever
	// the service's serving status changes.
	//
	// If the requested service is unknown when the call is received, the
	// server will send a message setting the serving status to
	// SERVICE_UNKNOWN but will *not* terminate the call.  If at some
	// future point, the serving status of the service becomes known, the
	// server will send a new message with the service's serving status.
	//
	// If the call terminates with status UNIMPLEMENTED, then clients
	// should assume this method is not supported and should not retry the
	// call.  If the call terminates with any other status (including OK),
	// clients should retry the call with appropriate exponential backoff.
	Watch(context.Context, *connect_go.Request[v1.HealthCheckRequest], *connect_go.ServerStream[v1.HealthCheckResponse]) error
}

type MessageServiceClient interface {
	// PushEvent pushes a given message to connect.runtime.v1.MessageService service.
	PushMessage(context.Context, *connect_go.Request[v1.PushMessageRequest]) (*connect_go.Response[v1.PushMessageResponse], error)
}

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

type MessageServiceController struct {
	// MessageService contains an instance of connect.runtime.v1.MessageService handler.
	MessageService runtimev1.MessageService
}

type MessageServiceHandler interface {
	// PushEvent pushes a given message to connect.runtime.v1.MessageService service.
	PushMessage(context.Context, *connect_go.Request[v1.PushMessageRequest]) (*connect_go.Response[v1.PushMessageResponse], error)
}

type ReflectionServiceController struct {
	// Services contains a collection of service names
	Services []string
}

type ServiceClientConfig struct {
	Client        *http.Client
	ClientURL     string
	ClientConfig  map[string]string
	ClientOptions []connect.ClientOption
}

type ServiceClientOption interface {
	// Apply applies the option.
	Apply(config *ServiceClientConfig)
}

type ServiceClientOptionFunc func(*ServiceClientConfig)

type UnimplementedEventServiceHandler struct{}

type UnimplementedHealthServiceHandler struct{}

type UnimplementedMessageServiceHandler struct{}