serverv1connect

package
v0.17.22 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AuthServiceGetTokenProcedure is the fully-qualified name of the AuthService's GetToken RPC.
	AuthServiceGetTokenProcedure = "/chalk.server.v1.AuthService/GetToken"
	// AuthServiceCreateLinkSessionProcedure is the fully-qualified name of the AuthService's
	// CreateLinkSession RPC.
	AuthServiceCreateLinkSessionProcedure = "/chalk.server.v1.AuthService/CreateLinkSession"
	// AuthServiceGetLinkSessionProcedure is the fully-qualified name of the AuthService's
	// GetLinkSession RPC.
	AuthServiceGetLinkSessionProcedure = "/chalk.server.v1.AuthService/GetLinkSession"
	// AuthServiceUpdateLinkSessionProcedure is the fully-qualified name of the AuthService's
	// UpdateLinkSession RPC.
	AuthServiceUpdateLinkSessionProcedure = "/chalk.server.v1.AuthService/UpdateLinkSession"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// AuthTestingServiceGetUnauthedTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetUnauthedTestEndpoint RPC.
	AuthTestingServiceGetUnauthedTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetUnauthedTestEndpoint"
	// AuthTestingServiceGetAuthedTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetAuthedTestEndpoint RPC.
	AuthTestingServiceGetAuthedTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetAuthedTestEndpoint"
	// AuthTestingServiceGetViewerTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetViewerTestEndpoint RPC.
	AuthTestingServiceGetViewerTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetViewerTestEndpoint"
	// AuthTestingServiceGetDataScientistTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetDataScientistTestEndpoint RPC.
	AuthTestingServiceGetDataScientistTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetDataScientistTestEndpoint"
	// AuthTestingServiceGetDeveloperTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetDeveloperTestEndpoint RPC.
	AuthTestingServiceGetDeveloperTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetDeveloperTestEndpoint"
	// AuthTestingServiceGetAdminTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetAdminTestEndpoint RPC.
	AuthTestingServiceGetAdminTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetAdminTestEndpoint"
	// AuthTestingServiceGetOwnerTestEndpointProcedure is the fully-qualified name of the
	// AuthTestingService's GetOwnerTestEndpoint RPC.
	AuthTestingServiceGetOwnerTestEndpointProcedure = "/chalk.server.v1.AuthTestingService/GetOwnerTestEndpoint"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// BillingServiceGetNodesAndPodsProcedure is the fully-qualified name of the BillingService's
	// GetNodesAndPods RPC.
	BillingServiceGetNodesAndPodsProcedure = "/chalk.server.v1.BillingService/GetNodesAndPods"
	// BillingServiceGetUsageChartProcedure is the fully-qualified name of the BillingService's
	// GetUsageChart RPC.
	BillingServiceGetUsageChartProcedure = "/chalk.server.v1.BillingService/GetUsageChart"
	// BillingServiceGetUtilizationRatesProcedure is the fully-qualified name of the BillingService's
	// GetUtilizationRates RPC.
	BillingServiceGetUtilizationRatesProcedure = "/chalk.server.v1.BillingService/GetUtilizationRates"
	// BillingServiceGetPodRequestChartsProcedure is the fully-qualified name of the BillingService's
	// GetPodRequestCharts RPC.
	BillingServiceGetPodRequestChartsProcedure = "/chalk.server.v1.BillingService/GetPodRequestCharts"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// BuilderServiceActivateDeploymentProcedure is the fully-qualified name of the BuilderService's
	// ActivateDeployment RPC.
	BuilderServiceActivateDeploymentProcedure = "/chalk.server.v1.BuilderService/ActivateDeployment"
	// BuilderServiceIndexDeploymentProcedure is the fully-qualified name of the BuilderService's
	// IndexDeployment RPC.
	BuilderServiceIndexDeploymentProcedure = "/chalk.server.v1.BuilderService/IndexDeployment"
	// BuilderServiceDeployKubeComponentsProcedure is the fully-qualified name of the BuilderService's
	// DeployKubeComponents RPC.
	BuilderServiceDeployKubeComponentsProcedure = "/chalk.server.v1.BuilderService/DeployKubeComponents"
	// BuilderServiceRebuildDeploymentProcedure is the fully-qualified name of the BuilderService's
	// RebuildDeployment RPC.
	BuilderServiceRebuildDeploymentProcedure = "/chalk.server.v1.BuilderService/RebuildDeployment"
	// BuilderServiceRedeployDeploymentProcedure is the fully-qualified name of the BuilderService's
	// RedeployDeployment RPC.
	BuilderServiceRedeployDeploymentProcedure = "/chalk.server.v1.BuilderService/RedeployDeployment"
	// BuilderServiceUploadSourceProcedure is the fully-qualified name of the BuilderService's
	// UploadSource RPC.
	BuilderServiceUploadSourceProcedure = "/chalk.server.v1.BuilderService/UploadSource"
	// BuilderServiceGetDeploymentStepsProcedure is the fully-qualified name of the BuilderService's
	// GetDeploymentSteps RPC.
	BuilderServiceGetDeploymentStepsProcedure = "/chalk.server.v1.BuilderService/GetDeploymentSteps"
	// BuilderServiceGetDeploymentLogsProcedure is the fully-qualified name of the BuilderService's
	// GetDeploymentLogs RPC.
	BuilderServiceGetDeploymentLogsProcedure = "/chalk.server.v1.BuilderService/GetDeploymentLogs"
	// BuilderServiceGetClusterTimescaleDBProcedure is the fully-qualified name of the BuilderService's
	// GetClusterTimescaleDB RPC.
	BuilderServiceGetClusterTimescaleDBProcedure = "/chalk.server.v1.BuilderService/GetClusterTimescaleDB"
	// BuilderServiceGetClusterGatewayProcedure is the fully-qualified name of the BuilderService's
	// GetClusterGateway RPC.
	BuilderServiceGetClusterGatewayProcedure = "/chalk.server.v1.BuilderService/GetClusterGateway"
	// BuilderServiceCreateClusterTimescaleDBProcedure is the fully-qualified name of the
	// BuilderService's CreateClusterTimescaleDB RPC.
	BuilderServiceCreateClusterTimescaleDBProcedure = "/chalk.server.v1.BuilderService/CreateClusterTimescaleDB"
	// BuilderServiceCreateClusterGatewayProcedure is the fully-qualified name of the BuilderService's
	// CreateClusterGateway RPC.
	BuilderServiceCreateClusterGatewayProcedure = "/chalk.server.v1.BuilderService/CreateClusterGateway"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// DeployServiceDeployBranchProcedure is the fully-qualified name of the DeployService's
	// DeployBranch RPC.
	DeployServiceDeployBranchProcedure = "/chalk.server.v1.DeployService/DeployBranch"
	// DeployServiceGetDeploymentProcedure is the fully-qualified name of the DeployService's
	// GetDeployment RPC.
	DeployServiceGetDeploymentProcedure = "/chalk.server.v1.DeployService/GetDeployment"
	// DeployServiceListDeploymentsProcedure is the fully-qualified name of the DeployService's
	// ListDeployments RPC.
	DeployServiceListDeploymentsProcedure = "/chalk.server.v1.DeployService/ListDeployments"
	// DeployServiceGetActiveDeploymentsProcedure is the fully-qualified name of the DeployService's
	// GetActiveDeployments RPC.
	DeployServiceGetActiveDeploymentsProcedure = "/chalk.server.v1.DeployService/GetActiveDeployments"
	// DeployServiceSuspendDeploymentProcedure is the fully-qualified name of the DeployService's
	// SuspendDeployment RPC.
	DeployServiceSuspendDeploymentProcedure = "/chalk.server.v1.DeployService/SuspendDeployment"
	// DeployServiceScaleDeploymentProcedure is the fully-qualified name of the DeployService's
	// ScaleDeployment RPC.
	DeployServiceScaleDeploymentProcedure = "/chalk.server.v1.DeployService/ScaleDeployment"
	// DeployServiceTagDeploymentProcedure is the fully-qualified name of the DeployService's
	// TagDeployment RPC.
	DeployServiceTagDeploymentProcedure = "/chalk.server.v1.DeployService/TagDeployment"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// FeatureFlagServiceGetFeatureFlagsProcedure is the fully-qualified name of the
	// FeatureFlagService's GetFeatureFlags RPC.
	FeatureFlagServiceGetFeatureFlagsProcedure = "/chalk.server.v1.FeatureFlagService/GetFeatureFlags"
	// FeatureFlagServiceSetFeatureFlagProcedure is the fully-qualified name of the FeatureFlagService's
	// SetFeatureFlag RPC.
	FeatureFlagServiceSetFeatureFlagProcedure = "/chalk.server.v1.FeatureFlagService/SetFeatureFlag"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// GraphServiceGetFeatureSQLProcedure is the fully-qualified name of the GraphService's
	// GetFeatureSQL RPC.
	GraphServiceGetFeatureSQLProcedure = "/chalk.server.v1.GraphService/GetFeatureSQL"
	// GraphServiceGetFeaturesMetadataProcedure is the fully-qualified name of the GraphService's
	// GetFeaturesMetadata RPC.
	GraphServiceGetFeaturesMetadataProcedure = "/chalk.server.v1.GraphService/GetFeaturesMetadata"
	// GraphServiceGetGraphProcedure is the fully-qualified name of the GraphService's GetGraph RPC.
	GraphServiceGetGraphProcedure = "/chalk.server.v1.GraphService/GetGraph"
	// GraphServiceUpdateGraphProcedure is the fully-qualified name of the GraphService's UpdateGraph
	// RPC.
	GraphServiceUpdateGraphProcedure = "/chalk.server.v1.GraphService/UpdateGraph"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// MonitoringServiceTestPagerDutyIntegrationProcedure is the fully-qualified name of the
	// MonitoringService's TestPagerDutyIntegration RPC.
	MonitoringServiceTestPagerDutyIntegrationProcedure = "/chalk.server.v1.MonitoringService/TestPagerDutyIntegration"
	// MonitoringServiceAddPagerDutyIntegrationProcedure is the fully-qualified name of the
	// MonitoringService's AddPagerDutyIntegration RPC.
	MonitoringServiceAddPagerDutyIntegrationProcedure = "/chalk.server.v1.MonitoringService/AddPagerDutyIntegration"
	// MonitoringServiceDeletePagerDutyIntegrationProcedure is the fully-qualified name of the
	// MonitoringService's DeletePagerDutyIntegration RPC.
	MonitoringServiceDeletePagerDutyIntegrationProcedure = "/chalk.server.v1.MonitoringService/DeletePagerDutyIntegration"
	// MonitoringServiceSetDefaultPagerDutyIntegrationProcedure is the fully-qualified name of the
	// MonitoringService's SetDefaultPagerDutyIntegration RPC.
	MonitoringServiceSetDefaultPagerDutyIntegrationProcedure = "/chalk.server.v1.MonitoringService/SetDefaultPagerDutyIntegration"
	// MonitoringServiceUpdatePagerDutyIntegrationProcedure is the fully-qualified name of the
	// MonitoringService's UpdatePagerDutyIntegration RPC.
	MonitoringServiceUpdatePagerDutyIntegrationProcedure = "/chalk.server.v1.MonitoringService/UpdatePagerDutyIntegration"
	// MonitoringServiceGetAllPagerDutyIntegrationsProcedure is the fully-qualified name of the
	// MonitoringService's GetAllPagerDutyIntegrations RPC.
	MonitoringServiceGetAllPagerDutyIntegrationsProcedure = "/chalk.server.v1.MonitoringService/GetAllPagerDutyIntegrations"
	// MonitoringServiceGetPagerDutyIntegrationProcedure is the fully-qualified name of the
	// MonitoringService's GetPagerDutyIntegration RPC.
	MonitoringServiceGetPagerDutyIntegrationProcedure = "/chalk.server.v1.MonitoringService/GetPagerDutyIntegration"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// NamedQueryServiceGetAllNamedQueriesProcedure is the fully-qualified name of the
	// NamedQueryService's GetAllNamedQueries RPC.
	NamedQueryServiceGetAllNamedQueriesProcedure = "/chalk.server.v1.NamedQueryService/GetAllNamedQueries"
	// NamedQueryServiceGetAllNamedQueriesActiveDeploymentProcedure is the fully-qualified name of the
	// NamedQueryService's GetAllNamedQueriesActiveDeployment RPC.
	NamedQueryServiceGetAllNamedQueriesActiveDeploymentProcedure = "/chalk.server.v1.NamedQueryService/GetAllNamedQueriesActiveDeployment"
	// NamedQueryServiceGetNamedQueryByNameProcedure is the fully-qualified name of the
	// NamedQueryService's GetNamedQueryByName RPC.
	NamedQueryServiceGetNamedQueryByNameProcedure = "/chalk.server.v1.NamedQueryService/GetNamedQueryByName"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// HealthServiceCheckHealthProcedure is the fully-qualified name of the HealthService's CheckHealth
	// RPC.
	HealthServiceCheckHealthProcedure = "/chalk.server.v1.HealthService/CheckHealth"
	// HealthServiceGetHealthProcedure is the fully-qualified name of the HealthService's GetHealth RPC.
	HealthServiceGetHealthProcedure = "/chalk.server.v1.HealthService/GetHealth"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// TeamServiceGetEnvProcedure is the fully-qualified name of the TeamService's GetEnv RPC.
	TeamServiceGetEnvProcedure = "/chalk.server.v1.TeamService/GetEnv"
	// TeamServiceGetEnvironmentsProcedure is the fully-qualified name of the TeamService's
	// GetEnvironments RPC.
	TeamServiceGetEnvironmentsProcedure = "/chalk.server.v1.TeamService/GetEnvironments"
	// TeamServiceGetAgentProcedure is the fully-qualified name of the TeamService's GetAgent RPC.
	TeamServiceGetAgentProcedure = "/chalk.server.v1.TeamService/GetAgent"
	// TeamServiceGetDisplayAgentProcedure is the fully-qualified name of the TeamService's
	// GetDisplayAgent RPC.
	TeamServiceGetDisplayAgentProcedure = "/chalk.server.v1.TeamService/GetDisplayAgent"
	// TeamServiceGetTeamProcedure is the fully-qualified name of the TeamService's GetTeam RPC.
	TeamServiceGetTeamProcedure = "/chalk.server.v1.TeamService/GetTeam"
	// TeamServiceCreateTeamProcedure is the fully-qualified name of the TeamService's CreateTeam RPC.
	TeamServiceCreateTeamProcedure = "/chalk.server.v1.TeamService/CreateTeam"
	// TeamServiceCreateProjectProcedure is the fully-qualified name of the TeamService's CreateProject
	// RPC.
	TeamServiceCreateProjectProcedure = "/chalk.server.v1.TeamService/CreateProject"
	// TeamServiceCreateEnvironmentProcedure is the fully-qualified name of the TeamService's
	// CreateEnvironment RPC.
	TeamServiceCreateEnvironmentProcedure = "/chalk.server.v1.TeamService/CreateEnvironment"
	// TeamServiceGetAvailablePermissionsProcedure is the fully-qualified name of the TeamService's
	// GetAvailablePermissions RPC.
	TeamServiceGetAvailablePermissionsProcedure = "/chalk.server.v1.TeamService/GetAvailablePermissions"
	// TeamServiceCreateServiceTokenProcedure is the fully-qualified name of the TeamService's
	// CreateServiceToken RPC.
	TeamServiceCreateServiceTokenProcedure = "/chalk.server.v1.TeamService/CreateServiceToken"
	// TeamServiceDeleteServiceTokenProcedure is the fully-qualified name of the TeamService's
	// DeleteServiceToken RPC.
	TeamServiceDeleteServiceTokenProcedure = "/chalk.server.v1.TeamService/DeleteServiceToken"
	// TeamServiceListServiceTokensProcedure is the fully-qualified name of the TeamService's
	// ListServiceTokens RPC.
	TeamServiceListServiceTokensProcedure = "/chalk.server.v1.TeamService/ListServiceTokens"
	// TeamServiceUpdateServiceTokenProcedure is the fully-qualified name of the TeamService's
	// UpdateServiceToken RPC.
	TeamServiceUpdateServiceTokenProcedure = "/chalk.server.v1.TeamService/UpdateServiceToken"
	// TeamServiceInviteTeamMemberProcedure is the fully-qualified name of the TeamService's
	// InviteTeamMember RPC.
	TeamServiceInviteTeamMemberProcedure = "/chalk.server.v1.TeamService/InviteTeamMember"
	// TeamServiceExpireTeamInviteProcedure is the fully-qualified name of the TeamService's
	// ExpireTeamInvite RPC.
	TeamServiceExpireTeamInviteProcedure = "/chalk.server.v1.TeamService/ExpireTeamInvite"
	// TeamServiceListTeamInvitesProcedure is the fully-qualified name of the TeamService's
	// ListTeamInvites RPC.
	TeamServiceListTeamInvitesProcedure = "/chalk.server.v1.TeamService/ListTeamInvites"
	// TeamServiceUpsertFeaturePermissionsProcedure is the fully-qualified name of the TeamService's
	// UpsertFeaturePermissions RPC.
	TeamServiceUpsertFeaturePermissionsProcedure = "/chalk.server.v1.TeamService/UpsertFeaturePermissions"
	// TeamServiceUpdateScimGroupSettingsProcedure is the fully-qualified name of the TeamService's
	// UpdateScimGroupSettings RPC.
	TeamServiceUpdateScimGroupSettingsProcedure = "/chalk.server.v1.TeamService/UpdateScimGroupSettings"
	// TeamServiceGetTeamPermissionsProcedure is the fully-qualified name of the TeamService's
	// GetTeamPermissions RPC.
	TeamServiceGetTeamPermissionsProcedure = "/chalk.server.v1.TeamService/GetTeamPermissions"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// TopicPushServiceListJobsProcedure is the fully-qualified name of the TopicPushService's ListJobs
	// RPC.
	TopicPushServiceListJobsProcedure = "/chalk.server.v1.TopicPushService/ListJobs"
	// TopicPushServiceCreateJobProcedure is the fully-qualified name of the TopicPushService's
	// CreateJob RPC.
	TopicPushServiceCreateJobProcedure = "/chalk.server.v1.TopicPushService/CreateJob"
	// TopicPushServiceUpdateJobProcedure is the fully-qualified name of the TopicPushService's
	// UpdateJob RPC.
	TopicPushServiceUpdateJobProcedure = "/chalk.server.v1.TopicPushService/UpdateJob"
	// TopicPushServiceDeleteJobProcedure is the fully-qualified name of the TopicPushService's
	// DeleteJob RPC.
	TopicPushServiceDeleteJobProcedure = "/chalk.server.v1.TopicPushService/DeleteJob"
	// TopicPushServiceGetJobByNameProcedure is the fully-qualified name of the TopicPushService's
	// GetJobByName RPC.
	TopicPushServiceGetJobByNameProcedure = "/chalk.server.v1.TopicPushService/GetJobByName"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// AuditServiceGetAuditLogsProcedure is the fully-qualified name of the AuditService's GetAuditLogs
	// RPC.
	AuditServiceGetAuditLogsProcedure = "/chalk.server.v1.AuditService/GetAuditLogs"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// AuditServiceName is the fully-qualified name of the AuditService service.
	AuditServiceName = "chalk.server.v1.AuditService"
)
View Source 
const (
	// AuthServiceName is the fully-qualified name of the AuthService service.
	AuthServiceName = "chalk.server.v1.AuthService"
)
View Source 
const (
	// AuthTestingServiceName is the fully-qualified name of the AuthTestingService service.
	AuthTestingServiceName = "chalk.server.v1.AuthTestingService"
)
View Source 
const (
	// BillingServiceName is the fully-qualified name of the BillingService service.
	BillingServiceName = "chalk.server.v1.BillingService"
)
View Source 
const (
	// BuilderServiceName is the fully-qualified name of the BuilderService service.
	BuilderServiceName = "chalk.server.v1.BuilderService"
)
View Source 
const (
	// CommandLineInterfaceServiceGetVersionsProcedure is the fully-qualified name of the
	// CommandLineInterfaceService's GetVersions RPC.
	CommandLineInterfaceServiceGetVersionsProcedure = "/chalk.server.v1.CommandLineInterfaceService/GetVersions"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// CommandLineInterfaceServiceName is the fully-qualified name of the CommandLineInterfaceService
	// service.
	CommandLineInterfaceServiceName = "chalk.server.v1.CommandLineInterfaceService"
)
View Source 
const (
	// DeployServiceName is the fully-qualified name of the DeployService service.
	DeployServiceName = "chalk.server.v1.DeployService"
)
View Source 
const (
	// FeatureFlagServiceName is the fully-qualified name of the FeatureFlagService service.
	FeatureFlagServiceName = "chalk.server.v1.FeatureFlagService"
)
View Source 
const (
	// GraphServiceName is the fully-qualified name of the GraphService service.
	GraphServiceName = "chalk.server.v1.GraphService"
)
View Source 
const (
	// HealthServiceName is the fully-qualified name of the HealthService service.
	HealthServiceName = "chalk.server.v1.HealthService"
)
View Source 
const (
	// MonitoringServiceName is the fully-qualified name of the MonitoringService service.
	MonitoringServiceName = "chalk.server.v1.MonitoringService"
)
View Source 
const (
	// NamedQueryServiceName is the fully-qualified name of the NamedQueryService service.
	NamedQueryServiceName = "chalk.server.v1.NamedQueryService"
)
View Source 
const (
	// TeamServiceName is the fully-qualified name of the TeamService service.
	TeamServiceName = "chalk.server.v1.TeamService"
)
View Source 
const (
	// TopicPushServiceName is the fully-qualified name of the TopicPushService service.
	TopicPushServiceName = "chalk.server.v1.TopicPushService"
)

Variables

This section is empty.

Functions

func NewAuditServiceHandler added in v0.8.3 

func NewAuditServiceHandler(svc AuditServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAuditServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewAuthServiceHandler 

func NewAuthServiceHandler(svc AuthServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAuthServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewAuthTestingServiceHandler added in v0.4.7 

func NewAuthTestingServiceHandler(svc AuthTestingServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAuthTestingServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewBillingServiceHandler 

func NewBillingServiceHandler(svc BillingServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewBillingServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewBuilderServiceHandler added in v0.16.18 

func NewBuilderServiceHandler(svc BuilderServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewBuilderServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewCommandLineInterfaceServiceHandler 

func NewCommandLineInterfaceServiceHandler(svc CommandLineInterfaceServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewCommandLineInterfaceServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewDeployServiceHandler 

func NewDeployServiceHandler(svc DeployServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDeployServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewFeatureFlagServiceHandler added in v0.7.6 

func NewFeatureFlagServiceHandler(svc FeatureFlagServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewFeatureFlagServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewGraphServiceHandler 

func NewGraphServiceHandler(svc GraphServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewGraphServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewHealthServiceHandler 

func NewHealthServiceHandler(svc HealthServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewHealthServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewMonitoringServiceHandler added in v0.4.7 

func NewMonitoringServiceHandler(svc MonitoringServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMonitoringServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewNamedQueryServiceHandler added in v0.14.5 

func NewNamedQueryServiceHandler(svc NamedQueryServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewNamedQueryServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewTeamServiceHandler 

func NewTeamServiceHandler(svc TeamServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTeamServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewTopicPushServiceHandler added in v0.11.2 

func NewTopicPushServiceHandler(svc TopicPushServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTopicPushServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type AuditServiceClient added in v0.8.3 

type AuditServiceClient interface {
	GetAuditLogs(context.Context, *connect.Request[v1.GetAuditLogsRequest]) (*connect.Response[v1.GetAuditLogsResponse], error)
}

AuditServiceClient is a client for the chalk.server.v1.AuditService service.

func NewAuditServiceClient added in v0.8.3 

func NewAuditServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AuditServiceClient

NewAuditServiceClient constructs a client for the chalk.server.v1.AuditService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AuditServiceHandler added in v0.8.3 

type AuditServiceHandler interface {
	GetAuditLogs(context.Context, *connect.Request[v1.GetAuditLogsRequest]) (*connect.Response[v1.GetAuditLogsResponse], error)
}

AuditServiceHandler is an implementation of the chalk.server.v1.AuditService service.

type AuthServiceClient 

type AuthServiceClient interface {
	GetToken(context.Context, *connect.Request[v1.GetTokenRequest]) (*connect.Response[v1.GetTokenResponse], error)
	CreateLinkSession(context.Context, *connect.Request[v1.CreateLinkSessionRequest]) (*connect.Response[v1.CreateLinkSessionResponse], error)
	GetLinkSession(context.Context, *connect.Request[v1.GetLinkSessionRequest]) (*connect.Response[v1.GetLinkSessionResponse], error)
	UpdateLinkSession(context.Context, *connect.Request[v1.UpdateLinkSessionRequest]) (*connect.Response[v1.UpdateLinkSessionResponse], error)
}

AuthServiceClient is a client for the chalk.server.v1.AuthService service.

func NewAuthServiceClient 

func NewAuthServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AuthServiceClient

NewAuthServiceClient constructs a client for the chalk.server.v1.AuthService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AuthServiceHandler 

type AuthServiceHandler interface {
	GetToken(context.Context, *connect.Request[v1.GetTokenRequest]) (*connect.Response[v1.GetTokenResponse], error)
	CreateLinkSession(context.Context, *connect.Request[v1.CreateLinkSessionRequest]) (*connect.Response[v1.CreateLinkSessionResponse], error)
	GetLinkSession(context.Context, *connect.Request[v1.GetLinkSessionRequest]) (*connect.Response[v1.GetLinkSessionResponse], error)
	UpdateLinkSession(context.Context, *connect.Request[v1.UpdateLinkSessionRequest]) (*connect.Response[v1.UpdateLinkSessionResponse], error)
}

AuthServiceHandler is an implementation of the chalk.server.v1.AuthService service.

type AuthTestingServiceClient added in v0.4.7 

type AuthTestingServiceClient interface {
	GetUnauthedTestEndpoint(context.Context, *connect.Request[v1.GetUnauthedTestEndpointRequest]) (*connect.Response[v1.GetUnauthedTestEndpointResponse], error)
	GetAuthedTestEndpoint(context.Context, *connect.Request[v1.GetAuthedTestEndpointRequest]) (*connect.Response[v1.GetAuthedTestEndpointResponse], error)
	GetViewerTestEndpoint(context.Context, *connect.Request[v1.GetViewerTestEndpointRequest]) (*connect.Response[v1.GetViewerTestEndpointResponse], error)
	GetDataScientistTestEndpoint(context.Context, *connect.Request[v1.GetDataScientistTestEndpointRequest]) (*connect.Response[v1.GetDataScientistTestEndpointResponse], error)
	GetDeveloperTestEndpoint(context.Context, *connect.Request[v1.GetDeveloperTestEndpointRequest]) (*connect.Response[v1.GetDeveloperTestEndpointResponse], error)
	GetAdminTestEndpoint(context.Context, *connect.Request[v1.GetAdminTestEndpointRequest]) (*connect.Response[v1.GetAdminTestEndpointResponse], error)
	GetOwnerTestEndpoint(context.Context, *connect.Request[v1.GetOwnerTestEndpointRequest]) (*connect.Response[v1.GetOwnerTestEndpointResponse], error)
}

AuthTestingServiceClient is a client for the chalk.server.v1.AuthTestingService service.

func NewAuthTestingServiceClient added in v0.4.7 

func NewAuthTestingServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AuthTestingServiceClient

NewAuthTestingServiceClient constructs a client for the chalk.server.v1.AuthTestingService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AuthTestingServiceHandler added in v0.4.7 

type AuthTestingServiceHandler interface {
	GetUnauthedTestEndpoint(context.Context, *connect.Request[v1.GetUnauthedTestEndpointRequest]) (*connect.Response[v1.GetUnauthedTestEndpointResponse], error)
	GetAuthedTestEndpoint(context.Context, *connect.Request[v1.GetAuthedTestEndpointRequest]) (*connect.Response[v1.GetAuthedTestEndpointResponse], error)
	GetViewerTestEndpoint(context.Context, *connect.Request[v1.GetViewerTestEndpointRequest]) (*connect.Response[v1.GetViewerTestEndpointResponse], error)
	GetDataScientistTestEndpoint(context.Context, *connect.Request[v1.GetDataScientistTestEndpointRequest]) (*connect.Response[v1.GetDataScientistTestEndpointResponse], error)
	GetDeveloperTestEndpoint(context.Context, *connect.Request[v1.GetDeveloperTestEndpointRequest]) (*connect.Response[v1.GetDeveloperTestEndpointResponse], error)
	GetAdminTestEndpoint(context.Context, *connect.Request[v1.GetAdminTestEndpointRequest]) (*connect.Response[v1.GetAdminTestEndpointResponse], error)
	GetOwnerTestEndpoint(context.Context, *connect.Request[v1.GetOwnerTestEndpointRequest]) (*connect.Response[v1.GetOwnerTestEndpointResponse], error)
}

AuthTestingServiceHandler is an implementation of the chalk.server.v1.AuthTestingService service.

type BillingServiceClient 

type BillingServiceClient interface {
	// GetNodesAndPods returns the nodes and pods for the team by default,
	// not just a single environment. To limit the scope, add filters to
	// the request object.
	GetNodesAndPods(context.Context, *connect.Request[v1.GetNodesAndPodsRequest]) (*connect.Response[v1.GetNodesAndPodsResponse], error)
	// GetUsageChart shows the Chalk credit usage between a provided start and
	// end period. The usage can be grouped by UsageChartPeriod for daily or
	// monthly usage, and by UsageChartGrouping for instance type or cluster usage.
	GetUsageChart(context.Context, *connect.Request[v1.GetUsageChartRequest]) (*connect.Response[v1.GetUsageChartResponse], error)
	// GetUtilizationRates returns the current utilization rates for all
	// instance types.
	GetUtilizationRates(context.Context, *connect.Request[v1.GetUtilizationRatesRequest]) (*connect.Response[v1.GetUtilizationRatesResponse], error)
	GetPodRequestCharts(context.Context, *connect.Request[v1.GetPodRequestChartsRequest]) (*connect.Response[v1.GetPodRequestChartsResponse], error)
}

BillingServiceClient is a client for the chalk.server.v1.BillingService service.

func NewBillingServiceClient 

func NewBillingServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) BillingServiceClient

NewBillingServiceClient constructs a client for the chalk.server.v1.BillingService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type BillingServiceHandler 

type BillingServiceHandler interface {
	// GetNodesAndPods returns the nodes and pods for the team by default,
	// not just a single environment. To limit the scope, add filters to
	// the request object.
	GetNodesAndPods(context.Context, *connect.Request[v1.GetNodesAndPodsRequest]) (*connect.Response[v1.GetNodesAndPodsResponse], error)
	// GetUsageChart shows the Chalk credit usage between a provided start and
	// end period. The usage can be grouped by UsageChartPeriod for daily or
	// monthly usage, and by UsageChartGrouping for instance type or cluster usage.
	GetUsageChart(context.Context, *connect.Request[v1.GetUsageChartRequest]) (*connect.Response[v1.GetUsageChartResponse], error)
	// GetUtilizationRates returns the current utilization rates for all
	// instance types.
	GetUtilizationRates(context.Context, *connect.Request[v1.GetUtilizationRatesRequest]) (*connect.Response[v1.GetUtilizationRatesResponse], error)
	GetPodRequestCharts(context.Context, *connect.Request[v1.GetPodRequestChartsRequest]) (*connect.Response[v1.GetPodRequestChartsResponse], error)
}

BillingServiceHandler is an implementation of the chalk.server.v1.BillingService service.

type BuilderServiceClient added in v0.16.18 

type BuilderServiceClient interface {
	// Takes an existing (past) deployment and promotes the k8s resources / other things associated with it.
	// Useful for debugging in local development where the auto activation doesn't work b/c no pubsub.
	ActivateDeployment(context.Context, *connect.Request[v1.ActivateDeploymentRequest]) (*connect.Response[v1.ActivateDeploymentResponse], error)
	IndexDeployment(context.Context, *connect.Request[v1.IndexDeploymentRequest]) (*connect.Response[v1.IndexDeploymentResponse], error)
	// Intermediate step in the deployment activation process. Allows for partial migration to the new
	// go-api-server builder service.
	DeployKubeComponents(context.Context, *connect.Request[v1.DeployKubeComponentsRequest]) (*connect.Response[v1.DeployKubeComponentsResponse], error)
	// Takes an existing (past) deployment and re-creates the image associated with it,
	// publishing the image as 'new_image_tag'.
	RebuildDeployment(context.Context, *connect.Request[v1.RebuildDeploymentRequest]) (*connect.Response[v1.RebuildDeploymentResponse], error)
	// Triggers a new build with the source code from this deployment and deploys the result
	RedeployDeployment(context.Context, *connect.Request[v1.RedeployDeploymentRequest]) (*connect.Response[v1.RedeployDeploymentResponse], error)
	// Triggers a new build with the provided source code archive and deploys the result
	UploadSource(context.Context, *connect.Request[v1.UploadSourceRequest]) (*connect.Response[v1.UploadSourceResponse], error)
	GetDeploymentSteps(context.Context, *connect.Request[v1.GetDeploymentStepsRequest]) (*connect.Response[v1.GetDeploymentStepsResponse], error)
	GetDeploymentLogs(context.Context, *connect.Request[v1.GetDeploymentLogsRequest]) (*connect.Response[v1.GetDeploymentLogsResponse], error)
	GetClusterTimescaleDB(context.Context, *connect.Request[v1.GetClusterTimescaleDBRequest]) (*connect.Response[v1.GetClusterTimescaleDBResponse], error)
	GetClusterGateway(context.Context, *connect.Request[v1.GetClusterGatewayRequest]) (*connect.Response[v1.GetClusterGatewayResponse], error)
	CreateClusterTimescaleDB(context.Context, *connect.Request[v1.CreateClusterTimescaleDBRequest]) (*connect.Response[v1.CreateClusterTimescaleDBResponse], error)
	CreateClusterGateway(context.Context, *connect.Request[v1.CreateClusterGatewayRequest]) (*connect.Response[v1.CreateClusterGatewayResponse], error)
}

BuilderServiceClient is a client for the chalk.server.v1.BuilderService service.

func NewBuilderServiceClient added in v0.16.18 

func NewBuilderServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) BuilderServiceClient

NewBuilderServiceClient constructs a client for the chalk.server.v1.BuilderService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type BuilderServiceHandler added in v0.16.18 

type BuilderServiceHandler interface {
	// Takes an existing (past) deployment and promotes the k8s resources / other things associated with it.
	// Useful for debugging in local development where the auto activation doesn't work b/c no pubsub.
	ActivateDeployment(context.Context, *connect.Request[v1.ActivateDeploymentRequest]) (*connect.Response[v1.ActivateDeploymentResponse], error)
	IndexDeployment(context.Context, *connect.Request[v1.IndexDeploymentRequest]) (*connect.Response[v1.IndexDeploymentResponse], error)
	// Intermediate step in the deployment activation process. Allows for partial migration to the new
	// go-api-server builder service.
	DeployKubeComponents(context.Context, *connect.Request[v1.DeployKubeComponentsRequest]) (*connect.Response[v1.DeployKubeComponentsResponse], error)
	// Takes an existing (past) deployment and re-creates the image associated with it,
	// publishing the image as 'new_image_tag'.
	RebuildDeployment(context.Context, *connect.Request[v1.RebuildDeploymentRequest]) (*connect.Response[v1.RebuildDeploymentResponse], error)
	// Triggers a new build with the source code from this deployment and deploys the result
	RedeployDeployment(context.Context, *connect.Request[v1.RedeployDeploymentRequest]) (*connect.Response[v1.RedeployDeploymentResponse], error)
	// Triggers a new build with the provided source code archive and deploys the result
	UploadSource(context.Context, *connect.Request[v1.UploadSourceRequest]) (*connect.Response[v1.UploadSourceResponse], error)
	GetDeploymentSteps(context.Context, *connect.Request[v1.GetDeploymentStepsRequest]) (*connect.Response[v1.GetDeploymentStepsResponse], error)
	GetDeploymentLogs(context.Context, *connect.Request[v1.GetDeploymentLogsRequest]) (*connect.Response[v1.GetDeploymentLogsResponse], error)
	GetClusterTimescaleDB(context.Context, *connect.Request[v1.GetClusterTimescaleDBRequest]) (*connect.Response[v1.GetClusterTimescaleDBResponse], error)
	GetClusterGateway(context.Context, *connect.Request[v1.GetClusterGatewayRequest]) (*connect.Response[v1.GetClusterGatewayResponse], error)
	CreateClusterTimescaleDB(context.Context, *connect.Request[v1.CreateClusterTimescaleDBRequest]) (*connect.Response[v1.CreateClusterTimescaleDBResponse], error)
	CreateClusterGateway(context.Context, *connect.Request[v1.CreateClusterGatewayRequest]) (*connect.Response[v1.CreateClusterGatewayResponse], error)
}

BuilderServiceHandler is an implementation of the chalk.server.v1.BuilderService service.

type CommandLineInterfaceServiceClient 

type CommandLineInterfaceServiceClient interface {
	GetVersions(context.Context, *connect.Request[v1.GetVersionsRequest]) (*connect.Response[v1.GetVersionsResponse], error)
}

CommandLineInterfaceServiceClient is a client for the chalk.server.v1.CommandLineInterfaceService service.

func NewCommandLineInterfaceServiceClient 

func NewCommandLineInterfaceServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) CommandLineInterfaceServiceClient

NewCommandLineInterfaceServiceClient constructs a client for the chalk.server.v1.CommandLineInterfaceService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type CommandLineInterfaceServiceHandler 

type CommandLineInterfaceServiceHandler interface {
	GetVersions(context.Context, *connect.Request[v1.GetVersionsRequest]) (*connect.Response[v1.GetVersionsResponse], error)
}

CommandLineInterfaceServiceHandler is an implementation of the chalk.server.v1.CommandLineInterfaceService service.

type DeployServiceClient 

type DeployServiceClient interface {
	DeployBranch(context.Context, *connect.Request[v1.DeployBranchRequest]) (*connect.Response[v1.DeployBranchResponse], error)
	GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error)
	ListDeployments(context.Context, *connect.Request[v1.ListDeploymentsRequest]) (*connect.Response[v1.ListDeploymentsResponse], error)
	GetActiveDeployments(context.Context, *connect.Request[v1.GetActiveDeploymentsRequest]) (*connect.Response[v1.GetActiveDeploymentsResponse], error)
	SuspendDeployment(context.Context, *connect.Request[v1.SuspendDeploymentRequest]) (*connect.Response[v1.SuspendDeploymentResponse], error)
	ScaleDeployment(context.Context, *connect.Request[v1.ScaleDeploymentRequest]) (*connect.Response[v1.ScaleDeploymentResponse], error)
	TagDeployment(context.Context, *connect.Request[v1.TagDeploymentRequest]) (*connect.Response[v1.TagDeploymentResponse], error)
}

DeployServiceClient is a client for the chalk.server.v1.DeployService service.

func NewDeployServiceClient 

func NewDeployServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DeployServiceClient

NewDeployServiceClient constructs a client for the chalk.server.v1.DeployService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type DeployServiceHandler 

type DeployServiceHandler interface {
	DeployBranch(context.Context, *connect.Request[v1.DeployBranchRequest]) (*connect.Response[v1.DeployBranchResponse], error)
	GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error)
	ListDeployments(context.Context, *connect.Request[v1.ListDeploymentsRequest]) (*connect.Response[v1.ListDeploymentsResponse], error)
	GetActiveDeployments(context.Context, *connect.Request[v1.GetActiveDeploymentsRequest]) (*connect.Response[v1.GetActiveDeploymentsResponse], error)
	SuspendDeployment(context.Context, *connect.Request[v1.SuspendDeploymentRequest]) (*connect.Response[v1.SuspendDeploymentResponse], error)
	ScaleDeployment(context.Context, *connect.Request[v1.ScaleDeploymentRequest]) (*connect.Response[v1.ScaleDeploymentResponse], error)
	TagDeployment(context.Context, *connect.Request[v1.TagDeploymentRequest]) (*connect.Response[v1.TagDeploymentResponse], error)
}

DeployServiceHandler is an implementation of the chalk.server.v1.DeployService service.

type FeatureFlagServiceClient added in v0.7.6 

type FeatureFlagServiceClient interface {
	GetFeatureFlags(context.Context, *connect.Request[v1.GetFeatureFlagsRequest]) (*connect.Response[v1.GetFeatureFlagsResponse], error)
	SetFeatureFlag(context.Context, *connect.Request[v1.SetFeatureFlagRequest]) (*connect.Response[v1.SetFeatureFlagResponse], error)
}

FeatureFlagServiceClient is a client for the chalk.server.v1.FeatureFlagService service.

func NewFeatureFlagServiceClient added in v0.7.6 

func NewFeatureFlagServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) FeatureFlagServiceClient

NewFeatureFlagServiceClient constructs a client for the chalk.server.v1.FeatureFlagService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type FeatureFlagServiceHandler added in v0.7.6 

type FeatureFlagServiceHandler interface {
	GetFeatureFlags(context.Context, *connect.Request[v1.GetFeatureFlagsRequest]) (*connect.Response[v1.GetFeatureFlagsResponse], error)
	SetFeatureFlag(context.Context, *connect.Request[v1.SetFeatureFlagRequest]) (*connect.Response[v1.SetFeatureFlagResponse], error)
}

FeatureFlagServiceHandler is an implementation of the chalk.server.v1.FeatureFlagService service.

type GraphServiceClient 

type GraphServiceClient interface {
	// GetFeatureSQL returns the feature SQLs for a given deployment.
	GetFeatureSQL(context.Context, *connect.Request[v1.GetFeatureSQLRequest]) (*connect.Response[v1.GetFeatureSQLResponse], error)
	GetFeaturesMetadata(context.Context, *connect.Request[v1.GetFeaturesMetadataRequest]) (*connect.Response[v1.GetFeaturesMetadataResponse], error)
	GetGraph(context.Context, *connect.Request[v1.GetGraphRequest]) (*connect.Response[v1.GetGraphResponse], error)
	// UpdateGraph uploads the protobuf graph for a given deployment.
	UpdateGraph(context.Context, *connect.Request[v1.UpdateGraphRequest]) (*connect.Response[v1.UpdateGraphResponse], error)
}

GraphServiceClient is a client for the chalk.server.v1.GraphService service.

func NewGraphServiceClient 

func NewGraphServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) GraphServiceClient

NewGraphServiceClient constructs a client for the chalk.server.v1.GraphService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type GraphServiceHandler 

type GraphServiceHandler interface {
	// GetFeatureSQL returns the feature SQLs for a given deployment.
	GetFeatureSQL(context.Context, *connect.Request[v1.GetFeatureSQLRequest]) (*connect.Response[v1.GetFeatureSQLResponse], error)
	GetFeaturesMetadata(context.Context, *connect.Request[v1.GetFeaturesMetadataRequest]) (*connect.Response[v1.GetFeaturesMetadataResponse], error)
	GetGraph(context.Context, *connect.Request[v1.GetGraphRequest]) (*connect.Response[v1.GetGraphResponse], error)
	// UpdateGraph uploads the protobuf graph for a given deployment.
	UpdateGraph(context.Context, *connect.Request[v1.UpdateGraphRequest]) (*connect.Response[v1.UpdateGraphResponse], error)
}

GraphServiceHandler is an implementation of the chalk.server.v1.GraphService service.

type HealthServiceClient 

type HealthServiceClient interface {
	// If any checks fail, this request fails.
	CheckHealth(context.Context, *connect.Request[v1.CheckHealthRequest]) (*connect.Response[v1.CheckHealthResponse], error)
	// Return the actual health check values.
	GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)
}

HealthServiceClient is a client for the chalk.server.v1.HealthService service.

func NewHealthServiceClient 

func NewHealthServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) HealthServiceClient

NewHealthServiceClient constructs a client for the chalk.server.v1.HealthService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type HealthServiceHandler 

type HealthServiceHandler interface {
	// If any checks fail, this request fails.
	CheckHealth(context.Context, *connect.Request[v1.CheckHealthRequest]) (*connect.Response[v1.CheckHealthResponse], error)
	// Return the actual health check values.
	GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)
}

HealthServiceHandler is an implementation of the chalk.server.v1.HealthService service.

type MonitoringServiceClient added in v0.4.7 

type MonitoringServiceClient interface {
	TestPagerDutyIntegration(context.Context, *connect.Request[v1.TestPagerDutyIntegrationRequest]) (*connect.Response[v1.TestPagerDutyIntegrationResponse], error)
	AddPagerDutyIntegration(context.Context, *connect.Request[v1.AddPagerDutyIntegrationRequest]) (*connect.Response[v1.AddPagerDutyIntegrationResponse], error)
	DeletePagerDutyIntegration(context.Context, *connect.Request[v1.DeletePagerDutyIntegrationRequest]) (*connect.Response[v1.DeletePagerDutyIntegrationResponse], error)
	SetDefaultPagerDutyIntegration(context.Context, *connect.Request[v1.SetDefaultPagerDutyIntegrationRequest]) (*connect.Response[v1.SetDefaultPagerDutyIntegrationResponse], error)
	UpdatePagerDutyIntegration(context.Context, *connect.Request[v1.UpdatePagerDutyIntegrationRequest]) (*connect.Response[v1.UpdatePagerDutyIntegrationResponse], error)
	GetAllPagerDutyIntegrations(context.Context, *connect.Request[v1.GetAllPagerDutyIntegrationsRequest]) (*connect.Response[v1.GetAllPagerDutyIntegrationsResponse], error)
	GetPagerDutyIntegration(context.Context, *connect.Request[v1.GetPagerDutyIntegrationRequest]) (*connect.Response[v1.GetPagerDutyIntegrationResponse], error)
}

MonitoringServiceClient is a client for the chalk.server.v1.MonitoringService service.

func NewMonitoringServiceClient added in v0.4.7 

func NewMonitoringServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MonitoringServiceClient

NewMonitoringServiceClient constructs a client for the chalk.server.v1.MonitoringService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type MonitoringServiceHandler added in v0.4.7 

type MonitoringServiceHandler interface {
	TestPagerDutyIntegration(context.Context, *connect.Request[v1.TestPagerDutyIntegrationRequest]) (*connect.Response[v1.TestPagerDutyIntegrationResponse], error)
	AddPagerDutyIntegration(context.Context, *connect.Request[v1.AddPagerDutyIntegrationRequest]) (*connect.Response[v1.AddPagerDutyIntegrationResponse], error)
	DeletePagerDutyIntegration(context.Context, *connect.Request[v1.DeletePagerDutyIntegrationRequest]) (*connect.Response[v1.DeletePagerDutyIntegrationResponse], error)
	SetDefaultPagerDutyIntegration(context.Context, *connect.Request[v1.SetDefaultPagerDutyIntegrationRequest]) (*connect.Response[v1.SetDefaultPagerDutyIntegrationResponse], error)
	UpdatePagerDutyIntegration(context.Context, *connect.Request[v1.UpdatePagerDutyIntegrationRequest]) (*connect.Response[v1.UpdatePagerDutyIntegrationResponse], error)
	GetAllPagerDutyIntegrations(context.Context, *connect.Request[v1.GetAllPagerDutyIntegrationsRequest]) (*connect.Response[v1.GetAllPagerDutyIntegrationsResponse], error)
	GetPagerDutyIntegration(context.Context, *connect.Request[v1.GetPagerDutyIntegrationRequest]) (*connect.Response[v1.GetPagerDutyIntegrationResponse], error)
}

MonitoringServiceHandler is an implementation of the chalk.server.v1.MonitoringService service.

type NamedQueryServiceClient added in v0.14.5 

type NamedQueryServiceClient interface {
	GetAllNamedQueries(context.Context, *connect.Request[v1.GetAllNamedQueriesRequest]) (*connect.Response[v1.GetAllNamedQueriesResponse], error)
	GetAllNamedQueriesActiveDeployment(context.Context, *connect.Request[v1.GetAllNamedQueriesActiveDeploymentRequest]) (*connect.Response[v1.GetAllNamedQueriesActiveDeploymentResponse], error)
	GetNamedQueryByName(context.Context, *connect.Request[v1.GetNamedQueryByNameRequest]) (*connect.Response[v1.GetNamedQueryByNameResponse], error)
}

NamedQueryServiceClient is a client for the chalk.server.v1.NamedQueryService service.

func NewNamedQueryServiceClient added in v0.14.5 

func NewNamedQueryServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) NamedQueryServiceClient

NewNamedQueryServiceClient constructs a client for the chalk.server.v1.NamedQueryService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type NamedQueryServiceHandler added in v0.14.5 

type NamedQueryServiceHandler interface {
	GetAllNamedQueries(context.Context, *connect.Request[v1.GetAllNamedQueriesRequest]) (*connect.Response[v1.GetAllNamedQueriesResponse], error)
	GetAllNamedQueriesActiveDeployment(context.Context, *connect.Request[v1.GetAllNamedQueriesActiveDeploymentRequest]) (*connect.Response[v1.GetAllNamedQueriesActiveDeploymentResponse], error)
	GetNamedQueryByName(context.Context, *connect.Request[v1.GetNamedQueryByNameRequest]) (*connect.Response[v1.GetNamedQueryByNameResponse], error)
}

NamedQueryServiceHandler is an implementation of the chalk.server.v1.NamedQueryService service.

type TeamServiceClient 

type TeamServiceClient interface {
	GetEnv(context.Context, *connect.Request[v1.GetEnvRequest]) (*connect.Response[v1.GetEnvResponse], error)
	GetEnvironments(context.Context, *connect.Request[v1.GetEnvironmentsRequest]) (*connect.Response[v1.GetEnvironmentsResponse], error)
	GetAgent(context.Context, *connect.Request[v1.GetAgentRequest]) (*connect.Response[v1.GetAgentResponse], error)
	GetDisplayAgent(context.Context, *connect.Request[v1.GetDisplayAgentRequest]) (*connect.Response[v1.GetDisplayAgentResponse], error)
	GetTeam(context.Context, *connect.Request[v1.GetTeamRequest]) (*connect.Response[v1.GetTeamResponse], error)
	CreateTeam(context.Context, *connect.Request[v1.CreateTeamRequest]) (*connect.Response[v1.CreateTeamResponse], error)
	CreateProject(context.Context, *connect.Request[v1.CreateProjectRequest]) (*connect.Response[v1.CreateProjectResponse], error)
	CreateEnvironment(context.Context, *connect.Request[v1.CreateEnvironmentRequest]) (*connect.Response[v1.CreateEnvironmentResponse], error)
	GetAvailablePermissions(context.Context, *connect.Request[v1.GetAvailablePermissionsRequest]) (*connect.Response[v1.GetAvailablePermissionsResponse], error)
	CreateServiceToken(context.Context, *connect.Request[v1.CreateServiceTokenRequest]) (*connect.Response[v1.CreateServiceTokenResponse], error)
	DeleteServiceToken(context.Context, *connect.Request[v1.DeleteServiceTokenRequest]) (*connect.Response[v1.DeleteServiceTokenResponse], error)
	ListServiceTokens(context.Context, *connect.Request[v1.ListServiceTokensRequest]) (*connect.Response[v1.ListServiceTokensResponse], error)
	UpdateServiceToken(context.Context, *connect.Request[v1.UpdateServiceTokenRequest]) (*connect.Response[v1.UpdateServiceTokenResponse], error)
	InviteTeamMember(context.Context, *connect.Request[v1.InviteTeamMemberRequest]) (*connect.Response[v1.InviteTeamMemberResponse], error)
	ExpireTeamInvite(context.Context, *connect.Request[v1.ExpireTeamInviteRequest]) (*connect.Response[v1.ExpireTeamInviteResponse], error)
	ListTeamInvites(context.Context, *connect.Request[v1.ListTeamInvitesRequest]) (*connect.Response[v1.ListTeamInvitesResponse], error)
	UpsertFeaturePermissions(context.Context, *connect.Request[v1.UpsertFeaturePermissionsRequest]) (*connect.Response[v1.UpsertFeaturePermissionsResponse], error)
	UpdateScimGroupSettings(context.Context, *connect.Request[v1.UpdateScimGroupSettingsRequest]) (*connect.Response[v1.UpdateScimGroupSettingsResponse], error)
	GetTeamPermissions(context.Context, *connect.Request[v1.GetTeamPermissionsRequest]) (*connect.Response[v1.GetTeamPermissionsResponse], error)
}

TeamServiceClient is a client for the chalk.server.v1.TeamService service.

func NewTeamServiceClient 

func NewTeamServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TeamServiceClient

NewTeamServiceClient constructs a client for the chalk.server.v1.TeamService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type TeamServiceHandler 

type TeamServiceHandler interface {
	GetEnv(context.Context, *connect.Request[v1.GetEnvRequest]) (*connect.Response[v1.GetEnvResponse], error)
	GetEnvironments(context.Context, *connect.Request[v1.GetEnvironmentsRequest]) (*connect.Response[v1.GetEnvironmentsResponse], error)
	GetAgent(context.Context, *connect.Request[v1.GetAgentRequest]) (*connect.Response[v1.GetAgentResponse], error)
	GetDisplayAgent(context.Context, *connect.Request[v1.GetDisplayAgentRequest]) (*connect.Response[v1.GetDisplayAgentResponse], error)
	GetTeam(context.Context, *connect.Request[v1.GetTeamRequest]) (*connect.Response[v1.GetTeamResponse], error)
	CreateTeam(context.Context, *connect.Request[v1.CreateTeamRequest]) (*connect.Response[v1.CreateTeamResponse], error)
	CreateProject(context.Context, *connect.Request[v1.CreateProjectRequest]) (*connect.Response[v1.CreateProjectResponse], error)
	CreateEnvironment(context.Context, *connect.Request[v1.CreateEnvironmentRequest]) (*connect.Response[v1.CreateEnvironmentResponse], error)
	GetAvailablePermissions(context.Context, *connect.Request[v1.GetAvailablePermissionsRequest]) (*connect.Response[v1.GetAvailablePermissionsResponse], error)
	CreateServiceToken(context.Context, *connect.Request[v1.CreateServiceTokenRequest]) (*connect.Response[v1.CreateServiceTokenResponse], error)
	DeleteServiceToken(context.Context, *connect.Request[v1.DeleteServiceTokenRequest]) (*connect.Response[v1.DeleteServiceTokenResponse], error)
	ListServiceTokens(context.Context, *connect.Request[v1.ListServiceTokensRequest]) (*connect.Response[v1.ListServiceTokensResponse], error)
	UpdateServiceToken(context.Context, *connect.Request[v1.UpdateServiceTokenRequest]) (*connect.Response[v1.UpdateServiceTokenResponse], error)
	InviteTeamMember(context.Context, *connect.Request[v1.InviteTeamMemberRequest]) (*connect.Response[v1.InviteTeamMemberResponse], error)
	ExpireTeamInvite(context.Context, *connect.Request[v1.ExpireTeamInviteRequest]) (*connect.Response[v1.ExpireTeamInviteResponse], error)
	ListTeamInvites(context.Context, *connect.Request[v1.ListTeamInvitesRequest]) (*connect.Response[v1.ListTeamInvitesResponse], error)
	UpsertFeaturePermissions(context.Context, *connect.Request[v1.UpsertFeaturePermissionsRequest]) (*connect.Response[v1.UpsertFeaturePermissionsResponse], error)
	UpdateScimGroupSettings(context.Context, *connect.Request[v1.UpdateScimGroupSettingsRequest]) (*connect.Response[v1.UpdateScimGroupSettingsResponse], error)
	GetTeamPermissions(context.Context, *connect.Request[v1.GetTeamPermissionsRequest]) (*connect.Response[v1.GetTeamPermissionsResponse], error)
}

TeamServiceHandler is an implementation of the chalk.server.v1.TeamService service.

type TopicPushServiceClient added in v0.11.2 

type TopicPushServiceClient interface {
	ListJobs(context.Context, *connect.Request[v1.ListJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)
	CreateJob(context.Context, *connect.Request[v1.CreateJobRequest]) (*connect.Response[v1.CreateJobResponse], error)
	UpdateJob(context.Context, *connect.Request[v1.UpdateJobRequest]) (*connect.Response[v1.UpdateJobResponse], error)
	DeleteJob(context.Context, *connect.Request[v1.DeleteJobRequest]) (*connect.Response[v1.DeleteJobResponse], error)
	GetJobByName(context.Context, *connect.Request[v1.GetJobByNameRequest]) (*connect.Response[v1.GetJobByNameResponse], error)
}

TopicPushServiceClient is a client for the chalk.server.v1.TopicPushService service.

func NewTopicPushServiceClient added in v0.11.2 

func NewTopicPushServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TopicPushServiceClient

NewTopicPushServiceClient constructs a client for the chalk.server.v1.TopicPushService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type TopicPushServiceHandler added in v0.11.2 

type TopicPushServiceHandler interface {
	ListJobs(context.Context, *connect.Request[v1.ListJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)
	CreateJob(context.Context, *connect.Request[v1.CreateJobRequest]) (*connect.Response[v1.CreateJobResponse], error)
	UpdateJob(context.Context, *connect.Request[v1.UpdateJobRequest]) (*connect.Response[v1.UpdateJobResponse], error)
	DeleteJob(context.Context, *connect.Request[v1.DeleteJobRequest]) (*connect.Response[v1.DeleteJobResponse], error)
	GetJobByName(context.Context, *connect.Request[v1.GetJobByNameRequest]) (*connect.Response[v1.GetJobByNameResponse], error)
}

TopicPushServiceHandler is an implementation of the chalk.server.v1.TopicPushService service.

type UnimplementedAuditServiceHandler added in v0.8.3 

type UnimplementedAuditServiceHandler struct{}

UnimplementedAuditServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAuditServiceHandler) GetAuditLogs added in v0.8.3 

func (UnimplementedAuditServiceHandler) GetAuditLogs(context.Context, *connect.Request[v1.GetAuditLogsRequest]) (*connect.Response[v1.GetAuditLogsResponse], error)

type UnimplementedAuthServiceHandler 

type UnimplementedAuthServiceHandler struct{}

UnimplementedAuthServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAuthServiceHandler) CreateLinkSession 

func (UnimplementedAuthServiceHandler) CreateLinkSession(context.Context, *connect.Request[v1.CreateLinkSessionRequest]) (*connect.Response[v1.CreateLinkSessionResponse], error)

func (UnimplementedAuthServiceHandler) GetLinkSession 

func (UnimplementedAuthServiceHandler) GetLinkSession(context.Context, *connect.Request[v1.GetLinkSessionRequest]) (*connect.Response[v1.GetLinkSessionResponse], error)

func (UnimplementedAuthServiceHandler) GetToken 

func (UnimplementedAuthServiceHandler) GetToken(context.Context, *connect.Request[v1.GetTokenRequest]) (*connect.Response[v1.GetTokenResponse], error)

func (UnimplementedAuthServiceHandler) UpdateLinkSession 

func (UnimplementedAuthServiceHandler) UpdateLinkSession(context.Context, *connect.Request[v1.UpdateLinkSessionRequest]) (*connect.Response[v1.UpdateLinkSessionResponse], error)

type UnimplementedAuthTestingServiceHandler added in v0.4.7 

type UnimplementedAuthTestingServiceHandler struct{}

UnimplementedAuthTestingServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAuthTestingServiceHandler) GetAdminTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetAdminTestEndpoint(context.Context, *connect.Request[v1.GetAdminTestEndpointRequest]) (*connect.Response[v1.GetAdminTestEndpointResponse], error)

func (UnimplementedAuthTestingServiceHandler) GetAuthedTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetAuthedTestEndpoint(context.Context, *connect.Request[v1.GetAuthedTestEndpointRequest]) (*connect.Response[v1.GetAuthedTestEndpointResponse], error)

func (UnimplementedAuthTestingServiceHandler) GetDataScientistTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetDataScientistTestEndpoint(context.Context, *connect.Request[v1.GetDataScientistTestEndpointRequest]) (*connect.Response[v1.GetDataScientistTestEndpointResponse], error)

func (UnimplementedAuthTestingServiceHandler) GetDeveloperTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetDeveloperTestEndpoint(context.Context, *connect.Request[v1.GetDeveloperTestEndpointRequest]) (*connect.Response[v1.GetDeveloperTestEndpointResponse], error)

func (UnimplementedAuthTestingServiceHandler) GetOwnerTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetOwnerTestEndpoint(context.Context, *connect.Request[v1.GetOwnerTestEndpointRequest]) (*connect.Response[v1.GetOwnerTestEndpointResponse], error)

func (UnimplementedAuthTestingServiceHandler) GetUnauthedTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetUnauthedTestEndpoint(context.Context, *connect.Request[v1.GetUnauthedTestEndpointRequest]) (*connect.Response[v1.GetUnauthedTestEndpointResponse], error)

func (UnimplementedAuthTestingServiceHandler) GetViewerTestEndpoint added in v0.4.7 

func (UnimplementedAuthTestingServiceHandler) GetViewerTestEndpoint(context.Context, *connect.Request[v1.GetViewerTestEndpointRequest]) (*connect.Response[v1.GetViewerTestEndpointResponse], error)

type UnimplementedBillingServiceHandler 

type UnimplementedBillingServiceHandler struct{}

UnimplementedBillingServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedBillingServiceHandler) GetNodesAndPods added in v0.12.3 

func (UnimplementedBillingServiceHandler) GetNodesAndPods(context.Context, *connect.Request[v1.GetNodesAndPodsRequest]) (*connect.Response[v1.GetNodesAndPodsResponse], error)

func (UnimplementedBillingServiceHandler) GetPodRequestCharts added in v0.17.17 

func (UnimplementedBillingServiceHandler) GetPodRequestCharts(context.Context, *connect.Request[v1.GetPodRequestChartsRequest]) (*connect.Response[v1.GetPodRequestChartsResponse], error)

func (UnimplementedBillingServiceHandler) GetUsageChart added in v0.4.7 

func (UnimplementedBillingServiceHandler) GetUsageChart(context.Context, *connect.Request[v1.GetUsageChartRequest]) (*connect.Response[v1.GetUsageChartResponse], error)

func (UnimplementedBillingServiceHandler) GetUtilizationRates added in v0.4.7 

func (UnimplementedBillingServiceHandler) GetUtilizationRates(context.Context, *connect.Request[v1.GetUtilizationRatesRequest]) (*connect.Response[v1.GetUtilizationRatesResponse], error)

type UnimplementedBuilderServiceHandler added in v0.16.18 

type UnimplementedBuilderServiceHandler struct{}

UnimplementedBuilderServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedBuilderServiceHandler) ActivateDeployment added in v0.16.18 

func (UnimplementedBuilderServiceHandler) ActivateDeployment(context.Context, *connect.Request[v1.ActivateDeploymentRequest]) (*connect.Response[v1.ActivateDeploymentResponse], error)

func (UnimplementedBuilderServiceHandler) CreateClusterGateway added in v0.17.20 

func (UnimplementedBuilderServiceHandler) CreateClusterGateway(context.Context, *connect.Request[v1.CreateClusterGatewayRequest]) (*connect.Response[v1.CreateClusterGatewayResponse], error)

func (UnimplementedBuilderServiceHandler) CreateClusterTimescaleDB added in v0.17.20 

func (UnimplementedBuilderServiceHandler) CreateClusterTimescaleDB(context.Context, *connect.Request[v1.CreateClusterTimescaleDBRequest]) (*connect.Response[v1.CreateClusterTimescaleDBResponse], error)

func (UnimplementedBuilderServiceHandler) DeployKubeComponents added in v0.16.23 

func (UnimplementedBuilderServiceHandler) DeployKubeComponents(context.Context, *connect.Request[v1.DeployKubeComponentsRequest]) (*connect.Response[v1.DeployKubeComponentsResponse], error)

func (UnimplementedBuilderServiceHandler) GetClusterGateway added in v0.17.20 

func (UnimplementedBuilderServiceHandler) GetClusterGateway(context.Context, *connect.Request[v1.GetClusterGatewayRequest]) (*connect.Response[v1.GetClusterGatewayResponse], error)

func (UnimplementedBuilderServiceHandler) GetClusterTimescaleDB added in v0.17.20 

func (UnimplementedBuilderServiceHandler) GetClusterTimescaleDB(context.Context, *connect.Request[v1.GetClusterTimescaleDBRequest]) (*connect.Response[v1.GetClusterTimescaleDBResponse], error)

func (UnimplementedBuilderServiceHandler) GetDeploymentLogs added in v0.17.20 

func (UnimplementedBuilderServiceHandler) GetDeploymentLogs(context.Context, *connect.Request[v1.GetDeploymentLogsRequest]) (*connect.Response[v1.GetDeploymentLogsResponse], error)

func (UnimplementedBuilderServiceHandler) GetDeploymentSteps added in v0.17.20 

func (UnimplementedBuilderServiceHandler) GetDeploymentSteps(context.Context, *connect.Request[v1.GetDeploymentStepsRequest]) (*connect.Response[v1.GetDeploymentStepsResponse], error)

func (UnimplementedBuilderServiceHandler) IndexDeployment added in v0.17.8 

func (UnimplementedBuilderServiceHandler) IndexDeployment(context.Context, *connect.Request[v1.IndexDeploymentRequest]) (*connect.Response[v1.IndexDeploymentResponse], error)

func (UnimplementedBuilderServiceHandler) RebuildDeployment added in v0.17.11 

func (UnimplementedBuilderServiceHandler) RebuildDeployment(context.Context, *connect.Request[v1.RebuildDeploymentRequest]) (*connect.Response[v1.RebuildDeploymentResponse], error)

func (UnimplementedBuilderServiceHandler) RedeployDeployment added in v0.17.13 

func (UnimplementedBuilderServiceHandler) RedeployDeployment(context.Context, *connect.Request[v1.RedeployDeploymentRequest]) (*connect.Response[v1.RedeployDeploymentResponse], error)

func (UnimplementedBuilderServiceHandler) UploadSource added in v0.17.13 

func (UnimplementedBuilderServiceHandler) UploadSource(context.Context, *connect.Request[v1.UploadSourceRequest]) (*connect.Response[v1.UploadSourceResponse], error)

type UnimplementedCommandLineInterfaceServiceHandler 

type UnimplementedCommandLineInterfaceServiceHandler struct{}

UnimplementedCommandLineInterfaceServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedCommandLineInterfaceServiceHandler) GetVersions 

func (UnimplementedCommandLineInterfaceServiceHandler) GetVersions(context.Context, *connect.Request[v1.GetVersionsRequest]) (*connect.Response[v1.GetVersionsResponse], error)

type UnimplementedDeployServiceHandler 

type UnimplementedDeployServiceHandler struct{}

UnimplementedDeployServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDeployServiceHandler) DeployBranch 

func (UnimplementedDeployServiceHandler) DeployBranch(context.Context, *connect.Request[v1.DeployBranchRequest]) (*connect.Response[v1.DeployBranchResponse], error)

func (UnimplementedDeployServiceHandler) GetActiveDeployments added in v0.17.9 

func (UnimplementedDeployServiceHandler) GetActiveDeployments(context.Context, *connect.Request[v1.GetActiveDeploymentsRequest]) (*connect.Response[v1.GetActiveDeploymentsResponse], error)

func (UnimplementedDeployServiceHandler) GetDeployment 

func (UnimplementedDeployServiceHandler) GetDeployment(context.Context, *connect.Request[v1.GetDeploymentRequest]) (*connect.Response[v1.GetDeploymentResponse], error)

func (UnimplementedDeployServiceHandler) ListDeployments added in v0.10.1 

func (UnimplementedDeployServiceHandler) ListDeployments(context.Context, *connect.Request[v1.ListDeploymentsRequest]) (*connect.Response[v1.ListDeploymentsResponse], error)

func (UnimplementedDeployServiceHandler) ScaleDeployment added in v0.12.0 

func (UnimplementedDeployServiceHandler) ScaleDeployment(context.Context, *connect.Request[v1.ScaleDeploymentRequest]) (*connect.Response[v1.ScaleDeploymentResponse], error)

func (UnimplementedDeployServiceHandler) SuspendDeployment added in v0.12.0 

func (UnimplementedDeployServiceHandler) SuspendDeployment(context.Context, *connect.Request[v1.SuspendDeploymentRequest]) (*connect.Response[v1.SuspendDeploymentResponse], error)

func (UnimplementedDeployServiceHandler) TagDeployment added in v0.12.0 

func (UnimplementedDeployServiceHandler) TagDeployment(context.Context, *connect.Request[v1.TagDeploymentRequest]) (*connect.Response[v1.TagDeploymentResponse], error)

type UnimplementedFeatureFlagServiceHandler added in v0.7.6 

type UnimplementedFeatureFlagServiceHandler struct{}

UnimplementedFeatureFlagServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedFeatureFlagServiceHandler) GetFeatureFlags added in v0.7.6 

func (UnimplementedFeatureFlagServiceHandler) GetFeatureFlags(context.Context, *connect.Request[v1.GetFeatureFlagsRequest]) (*connect.Response[v1.GetFeatureFlagsResponse], error)

func (UnimplementedFeatureFlagServiceHandler) SetFeatureFlag added in v0.7.6 

func (UnimplementedFeatureFlagServiceHandler) SetFeatureFlag(context.Context, *connect.Request[v1.SetFeatureFlagRequest]) (*connect.Response[v1.SetFeatureFlagResponse], error)

type UnimplementedGraphServiceHandler 

type UnimplementedGraphServiceHandler struct{}

UnimplementedGraphServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedGraphServiceHandler) GetFeatureSQL 

func (UnimplementedGraphServiceHandler) GetFeatureSQL(context.Context, *connect.Request[v1.GetFeatureSQLRequest]) (*connect.Response[v1.GetFeatureSQLResponse], error)

func (UnimplementedGraphServiceHandler) GetFeaturesMetadata 

func (UnimplementedGraphServiceHandler) GetFeaturesMetadata(context.Context, *connect.Request[v1.GetFeaturesMetadataRequest]) (*connect.Response[v1.GetFeaturesMetadataResponse], error)

func (UnimplementedGraphServiceHandler) GetGraph 

func (UnimplementedGraphServiceHandler) GetGraph(context.Context, *connect.Request[v1.GetGraphRequest]) (*connect.Response[v1.GetGraphResponse], error)

func (UnimplementedGraphServiceHandler) UpdateGraph 

func (UnimplementedGraphServiceHandler) UpdateGraph(context.Context, *connect.Request[v1.UpdateGraphRequest]) (*connect.Response[v1.UpdateGraphResponse], error)

type UnimplementedHealthServiceHandler 

type UnimplementedHealthServiceHandler struct{}

UnimplementedHealthServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedHealthServiceHandler) CheckHealth 

func (UnimplementedHealthServiceHandler) CheckHealth(context.Context, *connect.Request[v1.CheckHealthRequest]) (*connect.Response[v1.CheckHealthResponse], error)

func (UnimplementedHealthServiceHandler) GetHealth added in v0.17.18 

func (UnimplementedHealthServiceHandler) GetHealth(context.Context, *connect.Request[v1.GetHealthRequest]) (*connect.Response[v1.GetHealthResponse], error)

type UnimplementedMonitoringServiceHandler added in v0.4.7 

type UnimplementedMonitoringServiceHandler struct{}

UnimplementedMonitoringServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMonitoringServiceHandler) AddPagerDutyIntegration added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) AddPagerDutyIntegration(context.Context, *connect.Request[v1.AddPagerDutyIntegrationRequest]) (*connect.Response[v1.AddPagerDutyIntegrationResponse], error)

func (UnimplementedMonitoringServiceHandler) DeletePagerDutyIntegration added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) DeletePagerDutyIntegration(context.Context, *connect.Request[v1.DeletePagerDutyIntegrationRequest]) (*connect.Response[v1.DeletePagerDutyIntegrationResponse], error)

func (UnimplementedMonitoringServiceHandler) GetAllPagerDutyIntegrations added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) GetAllPagerDutyIntegrations(context.Context, *connect.Request[v1.GetAllPagerDutyIntegrationsRequest]) (*connect.Response[v1.GetAllPagerDutyIntegrationsResponse], error)

func (UnimplementedMonitoringServiceHandler) GetPagerDutyIntegration added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) GetPagerDutyIntegration(context.Context, *connect.Request[v1.GetPagerDutyIntegrationRequest]) (*connect.Response[v1.GetPagerDutyIntegrationResponse], error)

func (UnimplementedMonitoringServiceHandler) SetDefaultPagerDutyIntegration added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) SetDefaultPagerDutyIntegration(context.Context, *connect.Request[v1.SetDefaultPagerDutyIntegrationRequest]) (*connect.Response[v1.SetDefaultPagerDutyIntegrationResponse], error)

func (UnimplementedMonitoringServiceHandler) TestPagerDutyIntegration added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) TestPagerDutyIntegration(context.Context, *connect.Request[v1.TestPagerDutyIntegrationRequest]) (*connect.Response[v1.TestPagerDutyIntegrationResponse], error)

func (UnimplementedMonitoringServiceHandler) UpdatePagerDutyIntegration added in v0.4.7 

func (UnimplementedMonitoringServiceHandler) UpdatePagerDutyIntegration(context.Context, *connect.Request[v1.UpdatePagerDutyIntegrationRequest]) (*connect.Response[v1.UpdatePagerDutyIntegrationResponse], error)

type UnimplementedNamedQueryServiceHandler added in v0.14.5 

type UnimplementedNamedQueryServiceHandler struct{}

UnimplementedNamedQueryServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedNamedQueryServiceHandler) GetAllNamedQueries added in v0.14.5 

func (UnimplementedNamedQueryServiceHandler) GetAllNamedQueries(context.Context, *connect.Request[v1.GetAllNamedQueriesRequest]) (*connect.Response[v1.GetAllNamedQueriesResponse], error)

func (UnimplementedNamedQueryServiceHandler) GetAllNamedQueriesActiveDeployment added in v0.14.5 

func (UnimplementedNamedQueryServiceHandler) GetAllNamedQueriesActiveDeployment(context.Context, *connect.Request[v1.GetAllNamedQueriesActiveDeploymentRequest]) (*connect.Response[v1.GetAllNamedQueriesActiveDeploymentResponse], error)

func (UnimplementedNamedQueryServiceHandler) GetNamedQueryByName added in v0.16.14 

func (UnimplementedNamedQueryServiceHandler) GetNamedQueryByName(context.Context, *connect.Request[v1.GetNamedQueryByNameRequest]) (*connect.Response[v1.GetNamedQueryByNameResponse], error)

type UnimplementedTeamServiceHandler 

type UnimplementedTeamServiceHandler struct{}

UnimplementedTeamServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTeamServiceHandler) CreateEnvironment added in v0.4.7 

func (UnimplementedTeamServiceHandler) CreateEnvironment(context.Context, *connect.Request[v1.CreateEnvironmentRequest]) (*connect.Response[v1.CreateEnvironmentResponse], error)

func (UnimplementedTeamServiceHandler) CreateProject added in v0.4.7 

func (UnimplementedTeamServiceHandler) CreateProject(context.Context, *connect.Request[v1.CreateProjectRequest]) (*connect.Response[v1.CreateProjectResponse], error)

func (UnimplementedTeamServiceHandler) CreateServiceToken added in v0.4.7 

func (UnimplementedTeamServiceHandler) CreateServiceToken(context.Context, *connect.Request[v1.CreateServiceTokenRequest]) (*connect.Response[v1.CreateServiceTokenResponse], error)

func (UnimplementedTeamServiceHandler) CreateTeam added in v0.4.7 

func (UnimplementedTeamServiceHandler) CreateTeam(context.Context, *connect.Request[v1.CreateTeamRequest]) (*connect.Response[v1.CreateTeamResponse], error)

func (UnimplementedTeamServiceHandler) DeleteServiceToken added in v0.4.7 

func (UnimplementedTeamServiceHandler) DeleteServiceToken(context.Context, *connect.Request[v1.DeleteServiceTokenRequest]) (*connect.Response[v1.DeleteServiceTokenResponse], error)

func (UnimplementedTeamServiceHandler) ExpireTeamInvite added in v0.16.19 

func (UnimplementedTeamServiceHandler) ExpireTeamInvite(context.Context, *connect.Request[v1.ExpireTeamInviteRequest]) (*connect.Response[v1.ExpireTeamInviteResponse], error)

func (UnimplementedTeamServiceHandler) GetAgent 

func (UnimplementedTeamServiceHandler) GetAgent(context.Context, *connect.Request[v1.GetAgentRequest]) (*connect.Response[v1.GetAgentResponse], error)

func (UnimplementedTeamServiceHandler) GetAvailablePermissions added in v0.4.7 

func (UnimplementedTeamServiceHandler) GetAvailablePermissions(context.Context, *connect.Request[v1.GetAvailablePermissionsRequest]) (*connect.Response[v1.GetAvailablePermissionsResponse], error)

func (UnimplementedTeamServiceHandler) GetDisplayAgent 

func (UnimplementedTeamServiceHandler) GetDisplayAgent(context.Context, *connect.Request[v1.GetDisplayAgentRequest]) (*connect.Response[v1.GetDisplayAgentResponse], error)

func (UnimplementedTeamServiceHandler) GetEnv 

func (UnimplementedTeamServiceHandler) GetEnv(context.Context, *connect.Request[v1.GetEnvRequest]) (*connect.Response[v1.GetEnvResponse], error)

func (UnimplementedTeamServiceHandler) GetEnvironments 

func (UnimplementedTeamServiceHandler) GetEnvironments(context.Context, *connect.Request[v1.GetEnvironmentsRequest]) (*connect.Response[v1.GetEnvironmentsResponse], error)

func (UnimplementedTeamServiceHandler) GetTeam added in v0.4.7 

func (UnimplementedTeamServiceHandler) GetTeam(context.Context, *connect.Request[v1.GetTeamRequest]) (*connect.Response[v1.GetTeamResponse], error)

func (UnimplementedTeamServiceHandler) GetTeamPermissions added in v0.17.9 

func (UnimplementedTeamServiceHandler) GetTeamPermissions(context.Context, *connect.Request[v1.GetTeamPermissionsRequest]) (*connect.Response[v1.GetTeamPermissionsResponse], error)

func (UnimplementedTeamServiceHandler) InviteTeamMember added in v0.16.16 

func (UnimplementedTeamServiceHandler) InviteTeamMember(context.Context, *connect.Request[v1.InviteTeamMemberRequest]) (*connect.Response[v1.InviteTeamMemberResponse], error)

func (UnimplementedTeamServiceHandler) ListServiceTokens added in v0.7.2 

func (UnimplementedTeamServiceHandler) ListServiceTokens(context.Context, *connect.Request[v1.ListServiceTokensRequest]) (*connect.Response[v1.ListServiceTokensResponse], error)

func (UnimplementedTeamServiceHandler) ListTeamInvites added in v0.16.19 

func (UnimplementedTeamServiceHandler) ListTeamInvites(context.Context, *connect.Request[v1.ListTeamInvitesRequest]) (*connect.Response[v1.ListTeamInvitesResponse], error)

func (UnimplementedTeamServiceHandler) UpdateScimGroupSettings added in v0.16.9 

func (UnimplementedTeamServiceHandler) UpdateScimGroupSettings(context.Context, *connect.Request[v1.UpdateScimGroupSettingsRequest]) (*connect.Response[v1.UpdateScimGroupSettingsResponse], error)

func (UnimplementedTeamServiceHandler) UpdateServiceToken added in v0.7.2 

func (UnimplementedTeamServiceHandler) UpdateServiceToken(context.Context, *connect.Request[v1.UpdateServiceTokenRequest]) (*connect.Response[v1.UpdateServiceTokenResponse], error)

func (UnimplementedTeamServiceHandler) UpsertFeaturePermissions added in v0.6.1 

func (UnimplementedTeamServiceHandler) UpsertFeaturePermissions(context.Context, *connect.Request[v1.UpsertFeaturePermissionsRequest]) (*connect.Response[v1.UpsertFeaturePermissionsResponse], error)

type UnimplementedTopicPushServiceHandler added in v0.11.2 

type UnimplementedTopicPushServiceHandler struct{}

UnimplementedTopicPushServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTopicPushServiceHandler) CreateJob added in v0.11.2 

func (UnimplementedTopicPushServiceHandler) CreateJob(context.Context, *connect.Request[v1.CreateJobRequest]) (*connect.Response[v1.CreateJobResponse], error)

func (UnimplementedTopicPushServiceHandler) DeleteJob added in v0.11.2 

func (UnimplementedTopicPushServiceHandler) DeleteJob(context.Context, *connect.Request[v1.DeleteJobRequest]) (*connect.Response[v1.DeleteJobResponse], error)

func (UnimplementedTopicPushServiceHandler) GetJobByName added in v0.11.4 

func (UnimplementedTopicPushServiceHandler) GetJobByName(context.Context, *connect.Request[v1.GetJobByNameRequest]) (*connect.Response[v1.GetJobByNameResponse], error)

func (UnimplementedTopicPushServiceHandler) ListJobs added in v0.11.2 

func (UnimplementedTopicPushServiceHandler) ListJobs(context.Context, *connect.Request[v1.ListJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)

func (UnimplementedTopicPushServiceHandler) UpdateJob added in v0.11.2 

func (UnimplementedTopicPushServiceHandler) UpdateJob(context.Context, *connect.Request[v1.UpdateJobRequest]) (*connect.Response[v1.UpdateJobResponse], error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.