portabilityv1alpha1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2025 License: EUPL-1.2 Imports: 8 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	WaderService_ListTenants_FullMethodName          = "/portability.v1alpha1.WaderService/ListTenants"
	WaderService_GetTenant_FullMethodName            = "/portability.v1alpha1.WaderService/GetTenant"
	WaderService_ListApps_FullMethodName             = "/portability.v1alpha1.WaderService/ListApps"
	WaderService_GetApp_FullMethodName               = "/portability.v1alpha1.WaderService/GetApp"
	WaderService_GetCert_FullMethodName              = "/portability.v1alpha1.WaderService/GetCert"
	WaderService_ProxyTraffic_FullMethodName         = "/portability.v1alpha1.WaderService/ProxyTraffic"
	WaderService_ResumeTraffic_FullMethodName        = "/portability.v1alpha1.WaderService/ResumeTraffic"
	WaderService_StartObjectsSync_FullMethodName     = "/portability.v1alpha1.WaderService/StartObjectsSync"
	WaderService_StopObjectsSync_FullMethodName      = "/portability.v1alpha1.WaderService/StopObjectsSync"
	WaderService_GetObjectsSyncStatus_FullMethodName = "/portability.v1alpha1.WaderService/GetObjectsSyncStatus"
	WaderService_GetPostgresDump_FullMethodName      = "/portability.v1alpha1.WaderService/GetPostgresDump"
)

Variables

View Source 
var (
	SyncStatus_name = map[int32]string{
		0: "SYNC_STATUS_UNSPECIFIED",
		1: "SYNC_STATUS_COMPLETE",
		2: "SYNC_STATUS_PENDING",
		3: "SYNC_STATUS_FAILED",
	}
	SyncStatus_value = map[string]int32{
		"SYNC_STATUS_UNSPECIFIED": 0,
		"SYNC_STATUS_COMPLETE":    1,
		"SYNC_STATUS_PENDING":     2,
		"SYNC_STATUS_FAILED":      3,
	}
)

Enum value maps for SyncStatus.

View Source 
var File_proto_portability_v1alpha1_app_proto protoreflect.FileDescriptor
View Source 
var File_proto_portability_v1alpha1_network_proto protoreflect.FileDescriptor
View Source 
var File_proto_portability_v1alpha1_objects_proto protoreflect.FileDescriptor
View Source 
var File_proto_portability_v1alpha1_postgres_proto protoreflect.FileDescriptor
View Source 
var File_proto_portability_v1alpha1_service_proto protoreflect.FileDescriptor
View Source 
var File_proto_portability_v1alpha1_tenant_proto protoreflect.FileDescriptor
View Source 
var WaderService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "portability.v1alpha1.WaderService",
	HandlerType: (*WaderServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTenants",
			Handler:    _WaderService_ListTenants_Handler,
		},
		{
			MethodName: "GetTenant",
			Handler:    _WaderService_GetTenant_Handler,
		},
		{
			MethodName: "ListApps",
			Handler:    _WaderService_ListApps_Handler,
		},
		{
			MethodName: "GetApp",
			Handler:    _WaderService_GetApp_Handler,
		},
		{
			MethodName: "GetCert",
			Handler:    _WaderService_GetCert_Handler,
		},
		{
			MethodName: "ProxyTraffic",
			Handler:    _WaderService_ProxyTraffic_Handler,
		},
		{
			MethodName: "ResumeTraffic",
			Handler:    _WaderService_ResumeTraffic_Handler,
		},
		{
			MethodName: "StartObjectsSync",
			Handler:    _WaderService_StartObjectsSync_Handler,
		},
		{
			MethodName: "StopObjectsSync",
			Handler:    _WaderService_StopObjectsSync_Handler,
		},
		{
			MethodName: "GetObjectsSyncStatus",
			Handler:    _WaderService_GetObjectsSyncStatus_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetPostgresDump",
			Handler:       _WaderService_GetPostgresDump_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/portability/v1alpha1/service.proto",
}

WaderService_ServiceDesc is the grpc.ServiceDesc for WaderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWaderServiceServer 

func RegisterWaderServiceServer(s grpc.ServiceRegistrar, srv WaderServiceServer)

Types

type GetAppRequest added in v1.0.0 

type GetAppRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppRequest) Descriptor deprecated added in v1.0.0 

func (*GetAppRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAppRequest.ProtoReflect.Descriptor instead.

func (*GetAppRequest) GetSelectors added in v1.0.0 

func (x *GetAppRequest) GetSelectors() []string

func (*GetAppRequest) ProtoMessage added in v1.0.0 

func (*GetAppRequest) ProtoMessage()

func (*GetAppRequest) ProtoReflect added in v1.0.0 

func (x *GetAppRequest) ProtoReflect() protoreflect.Message

func (*GetAppRequest) Reset added in v1.0.0 

func (x *GetAppRequest) Reset()

func (*GetAppRequest) String added in v1.0.0 

func (x *GetAppRequest) String() string

type GetAppResponse added in v1.0.0 

type GetAppResponse struct {
	Application    []byte   `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
	ExtraManifests [][]byte `protobuf:"bytes,2,rep,name=extra_manifests,json=extraManifests,proto3" json:"extra_manifests,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAppResponse) Descriptor deprecated added in v1.0.0 

func (*GetAppResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetAppResponse.ProtoReflect.Descriptor instead.

func (*GetAppResponse) GetApplication added in v1.0.0 

func (x *GetAppResponse) GetApplication() []byte

func (*GetAppResponse) GetExtraManifests added in v1.0.0 

func (x *GetAppResponse) GetExtraManifests() [][]byte

func (*GetAppResponse) ProtoMessage added in v1.0.0 

func (*GetAppResponse) ProtoMessage()

func (*GetAppResponse) ProtoReflect added in v1.0.0 

func (x *GetAppResponse) ProtoReflect() protoreflect.Message

func (*GetAppResponse) Reset added in v1.0.0 

func (x *GetAppResponse) Reset()

func (*GetAppResponse) String added in v1.0.0 

func (x *GetAppResponse) String() string

type GetCertRequest 

type GetCertRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCertRequest) Descriptor deprecated 

func (*GetCertRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetCertRequest.ProtoReflect.Descriptor instead.

func (*GetCertRequest) GetSelectors 

func (x *GetCertRequest) GetSelectors() []string

func (*GetCertRequest) ProtoMessage 

func (*GetCertRequest) ProtoMessage()

func (*GetCertRequest) ProtoReflect 

func (x *GetCertRequest) ProtoReflect() protoreflect.Message

func (*GetCertRequest) Reset 

func (x *GetCertRequest) Reset()

func (*GetCertRequest) String 

func (x *GetCertRequest) String() string

type GetCertResponse 

type GetCertResponse struct {
	Crt []byte `protobuf:"bytes,1,opt,name=crt,proto3" json:"crt,omitempty"`
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Ca  []byte `protobuf:"bytes,3,opt,name=ca,proto3" json:"ca,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCertResponse) Descriptor deprecated 

func (*GetCertResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetCertResponse.ProtoReflect.Descriptor instead.

func (*GetCertResponse) GetCa 

func (x *GetCertResponse) GetCa() []byte

func (*GetCertResponse) GetCrt 

func (x *GetCertResponse) GetCrt() []byte

func (*GetCertResponse) GetKey 

func (x *GetCertResponse) GetKey() []byte

func (*GetCertResponse) ProtoMessage 

func (*GetCertResponse) ProtoMessage()

func (*GetCertResponse) ProtoReflect 

func (x *GetCertResponse) ProtoReflect() protoreflect.Message

func (*GetCertResponse) Reset 

func (x *GetCertResponse) Reset()

func (*GetCertResponse) String 

func (x *GetCertResponse) String() string

type GetObjectsSyncStatusRequest 

type GetObjectsSyncStatusRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Name      string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectsSyncStatusRequest) Descriptor deprecated 

func (*GetObjectsSyncStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetObjectsSyncStatusRequest.ProtoReflect.Descriptor instead.

func (*GetObjectsSyncStatusRequest) GetName 

func (x *GetObjectsSyncStatusRequest) GetName() string

func (*GetObjectsSyncStatusRequest) GetSelectors 

func (x *GetObjectsSyncStatusRequest) GetSelectors() []string

func (*GetObjectsSyncStatusRequest) ProtoMessage 

func (*GetObjectsSyncStatusRequest) ProtoMessage()

func (*GetObjectsSyncStatusRequest) ProtoReflect 

func (x *GetObjectsSyncStatusRequest) ProtoReflect() protoreflect.Message

func (*GetObjectsSyncStatusRequest) Reset 

func (x *GetObjectsSyncStatusRequest) Reset()

func (*GetObjectsSyncStatusRequest) String 

func (x *GetObjectsSyncStatusRequest) String() string

type GetObjectsSyncStatusResponse 

type GetObjectsSyncStatusResponse struct {
	Status SyncStatus `protobuf:"varint,1,opt,name=status,proto3,enum=portability.v1alpha1.SyncStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectsSyncStatusResponse) Descriptor deprecated 

func (*GetObjectsSyncStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetObjectsSyncStatusResponse.ProtoReflect.Descriptor instead.

func (*GetObjectsSyncStatusResponse) GetStatus 

func (x *GetObjectsSyncStatusResponse) GetStatus() SyncStatus

func (*GetObjectsSyncStatusResponse) ProtoMessage 

func (*GetObjectsSyncStatusResponse) ProtoMessage()

func (*GetObjectsSyncStatusResponse) ProtoReflect 

func (x *GetObjectsSyncStatusResponse) ProtoReflect() protoreflect.Message

func (*GetObjectsSyncStatusResponse) Reset 

func (x *GetObjectsSyncStatusResponse) Reset()

func (*GetObjectsSyncStatusResponse) String 

func (x *GetObjectsSyncStatusResponse) String() string

type GetPostgresDumpRequest 

type GetPostgresDumpRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Name      string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPostgresDumpRequest) Descriptor deprecated 

func (*GetPostgresDumpRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPostgresDumpRequest.ProtoReflect.Descriptor instead.

func (*GetPostgresDumpRequest) GetName 

func (x *GetPostgresDumpRequest) GetName() string

func (*GetPostgresDumpRequest) GetSelectors 

func (x *GetPostgresDumpRequest) GetSelectors() []string

func (*GetPostgresDumpRequest) ProtoMessage 

func (*GetPostgresDumpRequest) ProtoMessage()

func (*GetPostgresDumpRequest) ProtoReflect 

func (x *GetPostgresDumpRequest) ProtoReflect() protoreflect.Message

func (*GetPostgresDumpRequest) Reset 

func (x *GetPostgresDumpRequest) Reset()

func (*GetPostgresDumpRequest) String 

func (x *GetPostgresDumpRequest) String() string

type GetPostgresDumpResponse 

type GetPostgresDumpResponse struct {
	Dump []byte `protobuf:"bytes,1,opt,name=dump,proto3" json:"dump,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPostgresDumpResponse) Descriptor deprecated 

func (*GetPostgresDumpResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPostgresDumpResponse.ProtoReflect.Descriptor instead.

func (*GetPostgresDumpResponse) GetDump 

func (x *GetPostgresDumpResponse) GetDump() []byte

func (*GetPostgresDumpResponse) ProtoMessage 

func (*GetPostgresDumpResponse) ProtoMessage()

func (*GetPostgresDumpResponse) ProtoReflect 

func (x *GetPostgresDumpResponse) ProtoReflect() protoreflect.Message

func (*GetPostgresDumpResponse) Reset 

func (x *GetPostgresDumpResponse) Reset()

func (*GetPostgresDumpResponse) String 

func (x *GetPostgresDumpResponse) String() string

type GetTenantRequest 

type GetTenantRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTenantRequest) Descriptor deprecated 

func (*GetTenantRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTenantRequest.ProtoReflect.Descriptor instead.

func (*GetTenantRequest) GetSelectors 

func (x *GetTenantRequest) GetSelectors() []string

func (*GetTenantRequest) ProtoMessage 

func (*GetTenantRequest) ProtoMessage()

func (*GetTenantRequest) ProtoReflect 

func (x *GetTenantRequest) ProtoReflect() protoreflect.Message

func (*GetTenantRequest) Reset 

func (x *GetTenantRequest) Reset()

func (*GetTenantRequest) String 

func (x *GetTenantRequest) String() string

type GetTenantResponse 

type GetTenantResponse struct {
	Tenant         []byte   `protobuf:"bytes,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	ExtraManifests [][]byte `protobuf:"bytes,2,rep,name=extra_manifests,json=extraManifests,proto3" json:"extra_manifests,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTenantResponse) Descriptor deprecated 

func (*GetTenantResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetTenantResponse.ProtoReflect.Descriptor instead.

func (*GetTenantResponse) GetExtraManifests 

func (x *GetTenantResponse) GetExtraManifests() [][]byte

func (*GetTenantResponse) GetTenant 

func (x *GetTenantResponse) GetTenant() []byte

func (*GetTenantResponse) ProtoMessage 

func (*GetTenantResponse) ProtoMessage()

func (*GetTenantResponse) ProtoReflect 

func (x *GetTenantResponse) ProtoReflect() protoreflect.Message

func (*GetTenantResponse) Reset 

func (x *GetTenantResponse) Reset()

func (*GetTenantResponse) String 

func (x *GetTenantResponse) String() string

type ListAppsRequest 

type ListAppsRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAppsRequest) Descriptor deprecated 

func (*ListAppsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAppsRequest.ProtoReflect.Descriptor instead.

func (*ListAppsRequest) GetSelectors 

func (x *ListAppsRequest) GetSelectors() []string

func (*ListAppsRequest) ProtoMessage 

func (*ListAppsRequest) ProtoMessage()

func (*ListAppsRequest) ProtoReflect 

func (x *ListAppsRequest) ProtoReflect() protoreflect.Message

func (*ListAppsRequest) Reset 

func (x *ListAppsRequest) Reset()

func (*ListAppsRequest) String 

func (x *ListAppsRequest) String() string

type ListAppsResponse 

type ListAppsResponse struct {
	Apps []*ListAppsResponse_App `protobuf:"bytes,1,rep,name=apps,proto3" json:"apps,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAppsResponse) Descriptor deprecated 

func (*ListAppsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAppsResponse.ProtoReflect.Descriptor instead.

func (*ListAppsResponse) GetApps 

func (x *ListAppsResponse) GetApps() []*ListAppsResponse_App

func (*ListAppsResponse) ProtoMessage 

func (*ListAppsResponse) ProtoMessage()

func (*ListAppsResponse) ProtoReflect 

func (x *ListAppsResponse) ProtoReflect() protoreflect.Message

func (*ListAppsResponse) Reset 

func (x *ListAppsResponse) Reset()

func (*ListAppsResponse) String 

func (x *ListAppsResponse) String() string

type ListAppsResponse_App 

type ListAppsResponse_App struct {
	Name      string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Selectors []string `protobuf:"bytes,2,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAppsResponse_App) Descriptor deprecated 

func (*ListAppsResponse_App) Descriptor() ([]byte, []int)

Deprecated: Use ListAppsResponse_App.ProtoReflect.Descriptor instead.

func (*ListAppsResponse_App) GetName 

func (x *ListAppsResponse_App) GetName() string

func (*ListAppsResponse_App) GetSelectors 

func (x *ListAppsResponse_App) GetSelectors() []string

func (*ListAppsResponse_App) ProtoMessage 

func (*ListAppsResponse_App) ProtoMessage()

func (*ListAppsResponse_App) ProtoReflect 

func (x *ListAppsResponse_App) ProtoReflect() protoreflect.Message

func (*ListAppsResponse_App) Reset 

func (x *ListAppsResponse_App) Reset()

func (*ListAppsResponse_App) String 

func (x *ListAppsResponse_App) String() string

type ListTenantsRequest 

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

func (*ListTenantsRequest) Descriptor deprecated 

func (*ListTenantsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTenantsRequest.ProtoReflect.Descriptor instead.

func (*ListTenantsRequest) ProtoMessage 

func (*ListTenantsRequest) ProtoMessage()

func (*ListTenantsRequest) ProtoReflect 

func (x *ListTenantsRequest) ProtoReflect() protoreflect.Message

func (*ListTenantsRequest) Reset 

func (x *ListTenantsRequest) Reset()

func (*ListTenantsRequest) String 

func (x *ListTenantsRequest) String() string

type ListTenantsResponse 

type ListTenantsResponse struct {
	Tenants []*ListTenantsResponse_TenantSelector `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTenantsResponse) Descriptor deprecated 

func (*ListTenantsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTenantsResponse.ProtoReflect.Descriptor instead.

func (*ListTenantsResponse) GetTenants 

func (x *ListTenantsResponse) GetTenants() []*ListTenantsResponse_TenantSelector

func (*ListTenantsResponse) ProtoMessage 

func (*ListTenantsResponse) ProtoMessage()

func (*ListTenantsResponse) ProtoReflect 

func (x *ListTenantsResponse) ProtoReflect() protoreflect.Message

func (*ListTenantsResponse) Reset 

func (x *ListTenantsResponse) Reset()

func (*ListTenantsResponse) String 

func (x *ListTenantsResponse) String() string

type ListTenantsResponse_TenantSelector 

type ListTenantsResponse_TenantSelector struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTenantsResponse_TenantSelector) Descriptor deprecated 

func (*ListTenantsResponse_TenantSelector) Descriptor() ([]byte, []int)

Deprecated: Use ListTenantsResponse_TenantSelector.ProtoReflect.Descriptor instead.

func (*ListTenantsResponse_TenantSelector) GetSelectors 

func (x *ListTenantsResponse_TenantSelector) GetSelectors() []string

func (*ListTenantsResponse_TenantSelector) ProtoMessage 

func (*ListTenantsResponse_TenantSelector) ProtoMessage()

func (*ListTenantsResponse_TenantSelector) ProtoReflect 

func (x *ListTenantsResponse_TenantSelector) ProtoReflect() protoreflect.Message

func (*ListTenantsResponse_TenantSelector) Reset 

func (x *ListTenantsResponse_TenantSelector) Reset()

func (*ListTenantsResponse_TenantSelector) String 

func (x *ListTenantsResponse_TenantSelector) String() string

type ProxyTrafficRequest 

type ProxyTrafficRequest struct {
	Selectors   []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Destination string   `protobuf:"bytes,2,opt,name=destination,proto3" json:"destination,omitempty"`
	// contains filtered or unexported fields
}

func (*ProxyTrafficRequest) Descriptor deprecated 

func (*ProxyTrafficRequest) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTrafficRequest.ProtoReflect.Descriptor instead.

func (*ProxyTrafficRequest) GetDestination 

func (x *ProxyTrafficRequest) GetDestination() string

func (*ProxyTrafficRequest) GetSelectors 

func (x *ProxyTrafficRequest) GetSelectors() []string

func (*ProxyTrafficRequest) ProtoMessage 

func (*ProxyTrafficRequest) ProtoMessage()

func (*ProxyTrafficRequest) ProtoReflect 

func (x *ProxyTrafficRequest) ProtoReflect() protoreflect.Message

func (*ProxyTrafficRequest) Reset 

func (x *ProxyTrafficRequest) Reset()

func (*ProxyTrafficRequest) String 

func (x *ProxyTrafficRequest) String() string

type ProxyTrafficResponse 

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

func (*ProxyTrafficResponse) Descriptor deprecated 

func (*ProxyTrafficResponse) Descriptor() ([]byte, []int)

Deprecated: Use ProxyTrafficResponse.ProtoReflect.Descriptor instead.

func (*ProxyTrafficResponse) ProtoMessage 

func (*ProxyTrafficResponse) ProtoMessage()

func (*ProxyTrafficResponse) ProtoReflect 

func (x *ProxyTrafficResponse) ProtoReflect() protoreflect.Message

func (*ProxyTrafficResponse) Reset 

func (x *ProxyTrafficResponse) Reset()

func (*ProxyTrafficResponse) String 

func (x *ProxyTrafficResponse) String() string

type ResumeTrafficRequest 

type ResumeTrafficRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*ResumeTrafficRequest) Descriptor deprecated 

func (*ResumeTrafficRequest) Descriptor() ([]byte, []int)

Deprecated: Use ResumeTrafficRequest.ProtoReflect.Descriptor instead.

func (*ResumeTrafficRequest) GetSelectors 

func (x *ResumeTrafficRequest) GetSelectors() []string

func (*ResumeTrafficRequest) ProtoMessage 

func (*ResumeTrafficRequest) ProtoMessage()

func (*ResumeTrafficRequest) ProtoReflect 

func (x *ResumeTrafficRequest) ProtoReflect() protoreflect.Message

func (*ResumeTrafficRequest) Reset 

func (x *ResumeTrafficRequest) Reset()

func (*ResumeTrafficRequest) String 

func (x *ResumeTrafficRequest) String() string

type ResumeTrafficResponse 

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

func (*ResumeTrafficResponse) Descriptor deprecated 

func (*ResumeTrafficResponse) Descriptor() ([]byte, []int)

Deprecated: Use ResumeTrafficResponse.ProtoReflect.Descriptor instead.

func (*ResumeTrafficResponse) ProtoMessage 

func (*ResumeTrafficResponse) ProtoMessage()

func (*ResumeTrafficResponse) ProtoReflect 

func (x *ResumeTrafficResponse) ProtoReflect() protoreflect.Message

func (*ResumeTrafficResponse) Reset 

func (x *ResumeTrafficResponse) Reset()

func (*ResumeTrafficResponse) String 

func (x *ResumeTrafficResponse) String() string

type S3Client 

type S3Client struct {
	Url       string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Host      string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Bucket    string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	SecretKey string `protobuf:"bytes,4,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	AccessKey string `protobuf:"bytes,5,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	Insecure  bool   `protobuf:"varint,6,opt,name=insecure,proto3" json:"insecure,omitempty"`
	// contains filtered or unexported fields
}

func (*S3Client) Descriptor deprecated 

func (*S3Client) Descriptor() ([]byte, []int)

Deprecated: Use S3Client.ProtoReflect.Descriptor instead.

func (*S3Client) GetAccessKey 

func (x *S3Client) GetAccessKey() string

func (*S3Client) GetBucket 

func (x *S3Client) GetBucket() string

func (*S3Client) GetHost 

func (x *S3Client) GetHost() string

func (*S3Client) GetInsecure 

func (x *S3Client) GetInsecure() bool

func (*S3Client) GetSecretKey 

func (x *S3Client) GetSecretKey() string

func (*S3Client) GetUrl 

func (x *S3Client) GetUrl() string

func (*S3Client) ProtoMessage 

func (*S3Client) ProtoMessage()

func (*S3Client) ProtoReflect 

func (x *S3Client) ProtoReflect() protoreflect.Message

func (*S3Client) Reset 

func (x *S3Client) Reset()

func (*S3Client) String 

func (x *S3Client) String() string

type StartObjectsSyncRequest 

type StartObjectsSyncRequest struct {
	Selectors []string  `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Name      string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	S3Client  *S3Client `protobuf:"bytes,3,opt,name=s3_client,json=s3Client,proto3" json:"s3_client,omitempty"`
	// contains filtered or unexported fields
}

TODO rename selectors to instance_selectors everywhere

func (*StartObjectsSyncRequest) Descriptor deprecated 

func (*StartObjectsSyncRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartObjectsSyncRequest.ProtoReflect.Descriptor instead.

func (*StartObjectsSyncRequest) GetName 

func (x *StartObjectsSyncRequest) GetName() string

func (*StartObjectsSyncRequest) GetS3Client 

func (x *StartObjectsSyncRequest) GetS3Client() *S3Client

func (*StartObjectsSyncRequest) GetSelectors 

func (x *StartObjectsSyncRequest) GetSelectors() []string

func (*StartObjectsSyncRequest) ProtoMessage 

func (*StartObjectsSyncRequest) ProtoMessage()

func (*StartObjectsSyncRequest) ProtoReflect 

func (x *StartObjectsSyncRequest) ProtoReflect() protoreflect.Message

func (*StartObjectsSyncRequest) Reset 

func (x *StartObjectsSyncRequest) Reset()

func (*StartObjectsSyncRequest) String 

func (x *StartObjectsSyncRequest) String() string

type StartObjectsSyncResponse 

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

func (*StartObjectsSyncResponse) Descriptor deprecated 

func (*StartObjectsSyncResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartObjectsSyncResponse.ProtoReflect.Descriptor instead.

func (*StartObjectsSyncResponse) ProtoMessage 

func (*StartObjectsSyncResponse) ProtoMessage()

func (*StartObjectsSyncResponse) ProtoReflect 

func (x *StartObjectsSyncResponse) ProtoReflect() protoreflect.Message

func (*StartObjectsSyncResponse) Reset 

func (x *StartObjectsSyncResponse) Reset()

func (*StartObjectsSyncResponse) String 

func (x *StartObjectsSyncResponse) String() string

type StopObjectsSyncRequest 

type StopObjectsSyncRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	Name      string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*StopObjectsSyncRequest) Descriptor deprecated 

func (*StopObjectsSyncRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopObjectsSyncRequest.ProtoReflect.Descriptor instead.

func (*StopObjectsSyncRequest) GetName 

func (x *StopObjectsSyncRequest) GetName() string

func (*StopObjectsSyncRequest) GetSelectors 

func (x *StopObjectsSyncRequest) GetSelectors() []string

func (*StopObjectsSyncRequest) ProtoMessage 

func (*StopObjectsSyncRequest) ProtoMessage()

func (*StopObjectsSyncRequest) ProtoReflect 

func (x *StopObjectsSyncRequest) ProtoReflect() protoreflect.Message

func (*StopObjectsSyncRequest) Reset 

func (x *StopObjectsSyncRequest) Reset()

func (*StopObjectsSyncRequest) String 

func (x *StopObjectsSyncRequest) String() string

type StopObjectsSyncResponse 

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

func (*StopObjectsSyncResponse) Descriptor deprecated 

func (*StopObjectsSyncResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopObjectsSyncResponse.ProtoReflect.Descriptor instead.

func (*StopObjectsSyncResponse) ProtoMessage 

func (*StopObjectsSyncResponse) ProtoMessage()

func (*StopObjectsSyncResponse) ProtoReflect 

func (x *StopObjectsSyncResponse) ProtoReflect() protoreflect.Message

func (*StopObjectsSyncResponse) Reset 

func (x *StopObjectsSyncResponse) Reset()

func (*StopObjectsSyncResponse) String 

func (x *StopObjectsSyncResponse) String() string

type StopTrafficRequest 

type StopTrafficRequest struct {
	Selectors []string `protobuf:"bytes,1,rep,name=selectors,proto3" json:"selectors,omitempty"`
	// contains filtered or unexported fields
}

func (*StopTrafficRequest) Descriptor deprecated 

func (*StopTrafficRequest) Descriptor() ([]byte, []int)

Deprecated: Use StopTrafficRequest.ProtoReflect.Descriptor instead.

func (*StopTrafficRequest) GetSelectors 

func (x *StopTrafficRequest) GetSelectors() []string

func (*StopTrafficRequest) ProtoMessage 

func (*StopTrafficRequest) ProtoMessage()

func (*StopTrafficRequest) ProtoReflect 

func (x *StopTrafficRequest) ProtoReflect() protoreflect.Message

func (*StopTrafficRequest) Reset 

func (x *StopTrafficRequest) Reset()

func (*StopTrafficRequest) String 

func (x *StopTrafficRequest) String() string

type StopTrafficResponse 

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

func (*StopTrafficResponse) Descriptor deprecated 

func (*StopTrafficResponse) Descriptor() ([]byte, []int)

Deprecated: Use StopTrafficResponse.ProtoReflect.Descriptor instead.

func (*StopTrafficResponse) ProtoMessage 

func (*StopTrafficResponse) ProtoMessage()

func (*StopTrafficResponse) ProtoReflect 

func (x *StopTrafficResponse) ProtoReflect() protoreflect.Message

func (*StopTrafficResponse) Reset 

func (x *StopTrafficResponse) Reset()

func (*StopTrafficResponse) String 

func (x *StopTrafficResponse) String() string

type SyncStatus 

type SyncStatus int32
const (
	SyncStatus_SYNC_STATUS_UNSPECIFIED SyncStatus = 0
	SyncStatus_SYNC_STATUS_COMPLETE    SyncStatus = 1
	SyncStatus_SYNC_STATUS_PENDING     SyncStatus = 2
	SyncStatus_SYNC_STATUS_FAILED      SyncStatus = 3
)

func (SyncStatus) Descriptor 

func (SyncStatus) Descriptor() protoreflect.EnumDescriptor

func (SyncStatus) Enum 

func (x SyncStatus) Enum() *SyncStatus

func (SyncStatus) EnumDescriptor deprecated 

func (SyncStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use SyncStatus.Descriptor instead.

func (SyncStatus) Number 

func (x SyncStatus) Number() protoreflect.EnumNumber

func (SyncStatus) String 

func (x SyncStatus) String() string

func (SyncStatus) Type 

func (SyncStatus) Type() protoreflect.EnumType

type UnimplementedWaderServiceServer 

type UnimplementedWaderServiceServer struct {
}

UnimplementedWaderServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWaderServiceServer) GetApp 

func (UnimplementedWaderServiceServer) GetApp(context.Context, *GetAppRequest) (*GetAppResponse, error)

func (UnimplementedWaderServiceServer) GetCert 

func (UnimplementedWaderServiceServer) GetCert(context.Context, *GetCertRequest) (*GetCertResponse, error)

func (UnimplementedWaderServiceServer) GetObjectsSyncStatus 

func (UnimplementedWaderServiceServer) GetObjectsSyncStatus(context.Context, *GetObjectsSyncStatusRequest) (*GetObjectsSyncStatusResponse, error)

func (UnimplementedWaderServiceServer) GetPostgresDump 

func (UnimplementedWaderServiceServer) GetPostgresDump(*GetPostgresDumpRequest, WaderService_GetPostgresDumpServer) error

func (UnimplementedWaderServiceServer) GetTenant 

func (UnimplementedWaderServiceServer) GetTenant(context.Context, *GetTenantRequest) (*GetTenantResponse, error)

func (UnimplementedWaderServiceServer) ListApps 

func (UnimplementedWaderServiceServer) ListApps(context.Context, *ListAppsRequest) (*ListAppsResponse, error)

func (UnimplementedWaderServiceServer) ListTenants 

func (UnimplementedWaderServiceServer) ListTenants(context.Context, *ListTenantsRequest) (*ListTenantsResponse, error)

func (UnimplementedWaderServiceServer) ProxyTraffic 

func (UnimplementedWaderServiceServer) ProxyTraffic(context.Context, *ProxyTrafficRequest) (*ProxyTrafficResponse, error)

func (UnimplementedWaderServiceServer) ResumeTraffic 

func (UnimplementedWaderServiceServer) ResumeTraffic(context.Context, *ResumeTrafficRequest) (*ResumeTrafficResponse, error)

func (UnimplementedWaderServiceServer) StartObjectsSync 

func (UnimplementedWaderServiceServer) StartObjectsSync(context.Context, *StartObjectsSyncRequest) (*StartObjectsSyncResponse, error)

func (UnimplementedWaderServiceServer) StopObjectsSync 

func (UnimplementedWaderServiceServer) StopObjectsSync(context.Context, *StopObjectsSyncRequest) (*StopObjectsSyncResponse, error)

type UnsafeWaderServiceServer 

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

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

type WaderServiceClient 

type WaderServiceClient interface {
	ListTenants(ctx context.Context, in *ListTenantsRequest, opts ...grpc.CallOption) (*ListTenantsResponse, error)
	GetTenant(ctx context.Context, in *GetTenantRequest, opts ...grpc.CallOption) (*GetTenantResponse, error)
	ListApps(ctx context.Context, in *ListAppsRequest, opts ...grpc.CallOption) (*ListAppsResponse, error)
	GetApp(ctx context.Context, in *GetAppRequest, opts ...grpc.CallOption) (*GetAppResponse, error)
	GetCert(ctx context.Context, in *GetCertRequest, opts ...grpc.CallOption) (*GetCertResponse, error)
	ProxyTraffic(ctx context.Context, in *ProxyTrafficRequest, opts ...grpc.CallOption) (*ProxyTrafficResponse, error)
	ResumeTraffic(ctx context.Context, in *ResumeTrafficRequest, opts ...grpc.CallOption) (*ResumeTrafficResponse, error)
	StartObjectsSync(ctx context.Context, in *StartObjectsSyncRequest, opts ...grpc.CallOption) (*StartObjectsSyncResponse, error)
	StopObjectsSync(ctx context.Context, in *StopObjectsSyncRequest, opts ...grpc.CallOption) (*StopObjectsSyncResponse, error)
	GetObjectsSyncStatus(ctx context.Context, in *GetObjectsSyncStatusRequest, opts ...grpc.CallOption) (*GetObjectsSyncStatusResponse, error)
	GetPostgresDump(ctx context.Context, in *GetPostgresDumpRequest, opts ...grpc.CallOption) (WaderService_GetPostgresDumpClient, error)
}

WaderServiceClient is the client API for WaderService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWaderServiceClient 

func NewWaderServiceClient(cc grpc.ClientConnInterface) WaderServiceClient

type WaderServiceServer 

type WaderServiceServer interface {
	ListTenants(context.Context, *ListTenantsRequest) (*ListTenantsResponse, error)
	GetTenant(context.Context, *GetTenantRequest) (*GetTenantResponse, error)
	ListApps(context.Context, *ListAppsRequest) (*ListAppsResponse, error)
	GetApp(context.Context, *GetAppRequest) (*GetAppResponse, error)
	GetCert(context.Context, *GetCertRequest) (*GetCertResponse, error)
	ProxyTraffic(context.Context, *ProxyTrafficRequest) (*ProxyTrafficResponse, error)
	ResumeTraffic(context.Context, *ResumeTrafficRequest) (*ResumeTrafficResponse, error)
	StartObjectsSync(context.Context, *StartObjectsSyncRequest) (*StartObjectsSyncResponse, error)
	StopObjectsSync(context.Context, *StopObjectsSyncRequest) (*StopObjectsSyncResponse, error)
	GetObjectsSyncStatus(context.Context, *GetObjectsSyncStatusRequest) (*GetObjectsSyncStatusResponse, error)
	GetPostgresDump(*GetPostgresDumpRequest, WaderService_GetPostgresDumpServer) error
	// contains filtered or unexported methods
}

WaderServiceServer is the server API for WaderService service. All implementations must embed UnimplementedWaderServiceServer for forward compatibility

type WaderService_GetPostgresDumpClient 

type WaderService_GetPostgresDumpClient interface {
	Recv() (*GetPostgresDumpResponse, error)
	grpc.ClientStream
}

type WaderService_GetPostgresDumpServer 

type WaderService_GetPostgresDumpServer interface {
	Send(*GetPostgresDumpResponse) error
	grpc.ServerStream
}

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.