Documentation ¶
Index ¶
- Variables
- func RegisterPGSidecarServiceServer(s *grpc.Server, srv PGSidecarServiceServer)
- type AlterRoleReq
- func (*AlterRoleReq) Descriptor() ([]byte, []int)deprecated
- func (x *AlterRoleReq) GetRole() string
- func (x *AlterRoleReq) GetWith() *AlterRoleReq_Options
- func (*AlterRoleReq) ProtoMessage()
- func (x *AlterRoleReq) ProtoReflect() protoreflect.Message
- func (x *AlterRoleReq) Reset()
- func (x *AlterRoleReq) String() string
- type AlterRoleReq_Options
- func (*AlterRoleReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *AlterRoleReq_Options) GetConnectionLimit() int64
- func (x *AlterRoleReq_Options) GetCreatedb() bool
- func (x *AlterRoleReq_Options) GetCreaterole() bool
- func (x *AlterRoleReq_Options) GetCreateuser() bool
- func (x *AlterRoleReq_Options) GetInherit() bool
- func (x *AlterRoleReq_Options) GetNocreatedb() bool
- func (x *AlterRoleReq_Options) GetNocreaterole() bool
- func (x *AlterRoleReq_Options) GetNocreateuser() bool
- func (x *AlterRoleReq_Options) GetNoinherit() bool
- func (x *AlterRoleReq_Options) GetNoreplication() bool
- func (x *AlterRoleReq_Options) GetNosuperuser() bool
- func (x *AlterRoleReq_Options) GetPassword() *AlterRoleReq_Password
- func (x *AlterRoleReq_Options) GetReplication() bool
- func (x *AlterRoleReq_Options) GetSuperuser() bool
- func (*AlterRoleReq_Options) ProtoMessage()
- func (x *AlterRoleReq_Options) ProtoReflect() protoreflect.Message
- func (x *AlterRoleReq_Options) Reset()
- func (x *AlterRoleReq_Options) String() string
- type AlterRoleReq_Password
- func (*AlterRoleReq_Password) Descriptor() ([]byte, []int)deprecated
- func (x *AlterRoleReq_Password) GetUnencrypted() bool
- func (x *AlterRoleReq_Password) GetValue() string
- func (*AlterRoleReq_Password) ProtoMessage()
- func (x *AlterRoleReq_Password) ProtoReflect() protoreflect.Message
- func (x *AlterRoleReq_Password) Reset()
- func (x *AlterRoleReq_Password) String() string
- type AlterRoleRes
- type CreateDBReq
- type CreateDBRes
- type CreateExtensionReq
- func (*CreateExtensionReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreateExtensionReq) GetDb() string
- func (x *CreateExtensionReq) GetExt() string
- func (*CreateExtensionReq) ProtoMessage()
- func (x *CreateExtensionReq) ProtoReflect() protoreflect.Message
- func (x *CreateExtensionReq) Reset()
- func (x *CreateExtensionReq) String() string
- type CreateExtensionRes
- type DeploySqitchReq
- func (*DeploySqitchReq) Descriptor() ([]byte, []int)deprecated
- func (x *DeploySqitchReq) GetDb() string
- func (x *DeploySqitchReq) GetDir() string
- func (x *DeploySqitchReq) GetUser() string
- func (*DeploySqitchReq) ProtoMessage()
- func (x *DeploySqitchReq) ProtoReflect() protoreflect.Message
- func (x *DeploySqitchReq) Reset()
- func (x *DeploySqitchReq) String() string
- type DeploySqitchRes
- type DropTablesReq
- func (*DropTablesReq) Descriptor() ([]byte, []int)deprecated
- func (x *DropTablesReq) GetCascade() bool
- func (x *DropTablesReq) GetDb() string
- func (x *DropTablesReq) GetTables() []string
- func (*DropTablesReq) ProtoMessage()
- func (x *DropTablesReq) ProtoReflect() protoreflect.Message
- func (x *DropTablesReq) Reset()
- func (x *DropTablesReq) String() string
- type DropTablesRes
- type ErrorDetails
- type ErrorDetails_Codes
- func (ErrorDetails_Codes) Descriptor() protoreflect.EnumDescriptor
- func (x ErrorDetails_Codes) Enum() *ErrorDetails_Codes
- func (ErrorDetails_Codes) EnumDescriptor() ([]byte, []int)deprecated
- func (x ErrorDetails_Codes) Number() protoreflect.EnumNumber
- func (x ErrorDetails_Codes) String() string
- func (ErrorDetails_Codes) Type() protoreflect.EnumType
- type MigrateTablesReq
- func (*MigrateTablesReq) Descriptor() ([]byte, []int)deprecated
- func (x *MigrateTablesReq) GetFailIfSrcDbMissing() bool
- func (x *MigrateTablesReq) GetFromDb() string
- func (x *MigrateTablesReq) GetImportUser() string
- func (x *MigrateTablesReq) GetSkipDbCreate() bool
- func (x *MigrateTablesReq) GetTable() []string
- func (x *MigrateTablesReq) GetToDb() string
- func (*MigrateTablesReq) ProtoMessage()
- func (x *MigrateTablesReq) ProtoReflect() protoreflect.Message
- func (x *MigrateTablesReq) Reset()
- func (x *MigrateTablesReq) String() string
- type MigrateTablesRes
- type PGSidecarServiceClient
- type PGSidecarServiceServer
- type RenameDBReq
- type RenameDBRes
- type SetPublicSchemaRoleReq
- func (*SetPublicSchemaRoleReq) Descriptor() ([]byte, []int)deprecated
- func (x *SetPublicSchemaRoleReq) GetDb() string
- func (x *SetPublicSchemaRoleReq) GetRole() string
- func (*SetPublicSchemaRoleReq) ProtoMessage()
- func (x *SetPublicSchemaRoleReq) ProtoReflect() protoreflect.Message
- func (x *SetPublicSchemaRoleReq) Reset()
- func (x *SetPublicSchemaRoleReq) String() string
- type SetPublicSchemaRoleRes
- type UnimplementedPGSidecarServiceServer
- func (*UnimplementedPGSidecarServiceServer) AlterRole(context.Context, *AlterRoleReq) (*AlterRoleRes, error)
- func (*UnimplementedPGSidecarServiceServer) CreateDB(context.Context, *CreateDBReq) (*CreateDBRes, error)
- func (*UnimplementedPGSidecarServiceServer) CreateExtension(context.Context, *CreateExtensionReq) (*CreateExtensionRes, error)
- func (*UnimplementedPGSidecarServiceServer) DeploySqitch(context.Context, *DeploySqitchReq) (*DeploySqitchRes, error)
- func (*UnimplementedPGSidecarServiceServer) DropTables(context.Context, *DropTablesReq) (*DropTablesRes, error)
- func (*UnimplementedPGSidecarServiceServer) MigrateTables(context.Context, *MigrateTablesReq) (*MigrateTablesRes, error)
- func (*UnimplementedPGSidecarServiceServer) RenameDB(context.Context, *RenameDBReq) (*RenameDBRes, error)
- func (*UnimplementedPGSidecarServiceServer) SetPublicSchemaRole(context.Context, *SetPublicSchemaRoleReq) (*SetPublicSchemaRoleRes, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrorDetails_Codes_name = map[int32]string{ 0: "SRC_DB_MISSING", } ErrorDetails_Codes_value = map[string]int32{ "SRC_DB_MISSING": 0, } )
Enum value maps for ErrorDetails_Codes.
var File_interservice_pg_sidecar_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterPGSidecarServiceServer ¶
func RegisterPGSidecarServiceServer(s *grpc.Server, srv PGSidecarServiceServer)
Types ¶
type AlterRoleReq ¶
type AlterRoleReq struct { Role string `protobuf:"bytes,20,opt,name=role,proto3" json:"role,omitempty" toml:"role,omitempty" mapstructure:"role,omitempty"` With *AlterRoleReq_Options `protobuf:"bytes,21,opt,name=with,proto3" json:"with,omitempty" toml:"with,omitempty" mapstructure:"with,omitempty"` // contains filtered or unexported fields }
func (*AlterRoleReq) Descriptor
deprecated
func (*AlterRoleReq) Descriptor() ([]byte, []int)
Deprecated: Use AlterRoleReq.ProtoReflect.Descriptor instead.
func (*AlterRoleReq) GetRole ¶
func (x *AlterRoleReq) GetRole() string
func (*AlterRoleReq) GetWith ¶
func (x *AlterRoleReq) GetWith() *AlterRoleReq_Options
func (*AlterRoleReq) ProtoMessage ¶
func (*AlterRoleReq) ProtoMessage()
func (*AlterRoleReq) ProtoReflect ¶
func (x *AlterRoleReq) ProtoReflect() protoreflect.Message
func (*AlterRoleReq) Reset ¶
func (x *AlterRoleReq) Reset()
func (*AlterRoleReq) String ¶
func (x *AlterRoleReq) String() string
type AlterRoleReq_Options ¶
type AlterRoleReq_Options struct { Superuser bool `` /* 135-byte string literal not displayed */ Nosuperuser bool `` /* 143-byte string literal not displayed */ Createdb bool `` /* 131-byte string literal not displayed */ Nocreatedb bool `` /* 139-byte string literal not displayed */ Createrole bool `` /* 139-byte string literal not displayed */ Nocreaterole bool `` /* 147-byte string literal not displayed */ Createuser bool `` /* 139-byte string literal not displayed */ Nocreateuser bool `` /* 147-byte string literal not displayed */ Inherit bool `` /* 127-byte string literal not displayed */ Noinherit bool `` /* 135-byte string literal not displayed */ Replication bool `` /* 143-byte string literal not displayed */ Noreplication bool `` /* 151-byte string literal not displayed */ ConnectionLimit int64 `` /* 184-byte string literal not displayed */ Password *AlterRoleReq_Password `` // TODO: Add VALID UNTIL with a timestamp /* 130-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AlterRoleReq_Options) Descriptor
deprecated
func (*AlterRoleReq_Options) Descriptor() ([]byte, []int)
Deprecated: Use AlterRoleReq_Options.ProtoReflect.Descriptor instead.
func (*AlterRoleReq_Options) GetConnectionLimit ¶
func (x *AlterRoleReq_Options) GetConnectionLimit() int64
func (*AlterRoleReq_Options) GetCreatedb ¶
func (x *AlterRoleReq_Options) GetCreatedb() bool
func (*AlterRoleReq_Options) GetCreaterole ¶
func (x *AlterRoleReq_Options) GetCreaterole() bool
func (*AlterRoleReq_Options) GetCreateuser ¶
func (x *AlterRoleReq_Options) GetCreateuser() bool
func (*AlterRoleReq_Options) GetInherit ¶
func (x *AlterRoleReq_Options) GetInherit() bool
func (*AlterRoleReq_Options) GetNocreatedb ¶
func (x *AlterRoleReq_Options) GetNocreatedb() bool
func (*AlterRoleReq_Options) GetNocreaterole ¶
func (x *AlterRoleReq_Options) GetNocreaterole() bool
func (*AlterRoleReq_Options) GetNocreateuser ¶
func (x *AlterRoleReq_Options) GetNocreateuser() bool
func (*AlterRoleReq_Options) GetNoinherit ¶
func (x *AlterRoleReq_Options) GetNoinherit() bool
func (*AlterRoleReq_Options) GetNoreplication ¶
func (x *AlterRoleReq_Options) GetNoreplication() bool
func (*AlterRoleReq_Options) GetNosuperuser ¶
func (x *AlterRoleReq_Options) GetNosuperuser() bool
func (*AlterRoleReq_Options) GetPassword ¶
func (x *AlterRoleReq_Options) GetPassword() *AlterRoleReq_Password
func (*AlterRoleReq_Options) GetReplication ¶
func (x *AlterRoleReq_Options) GetReplication() bool
func (*AlterRoleReq_Options) GetSuperuser ¶
func (x *AlterRoleReq_Options) GetSuperuser() bool
func (*AlterRoleReq_Options) ProtoMessage ¶
func (*AlterRoleReq_Options) ProtoMessage()
func (*AlterRoleReq_Options) ProtoReflect ¶
func (x *AlterRoleReq_Options) ProtoReflect() protoreflect.Message
func (*AlterRoleReq_Options) Reset ¶
func (x *AlterRoleReq_Options) Reset()
func (*AlterRoleReq_Options) String ¶
func (x *AlterRoleReq_Options) String() string
type AlterRoleReq_Password ¶
type AlterRoleReq_Password struct { Value string `protobuf:"bytes,20,opt,name=value,proto3" json:"value,omitempty" toml:"value,omitempty" mapstructure:"value,omitempty"` Unencrypted bool `` // default to encrypted /* 143-byte string literal not displayed */ // contains filtered or unexported fields }
func (*AlterRoleReq_Password) Descriptor
deprecated
func (*AlterRoleReq_Password) Descriptor() ([]byte, []int)
Deprecated: Use AlterRoleReq_Password.ProtoReflect.Descriptor instead.
func (*AlterRoleReq_Password) GetUnencrypted ¶
func (x *AlterRoleReq_Password) GetUnencrypted() bool
func (*AlterRoleReq_Password) GetValue ¶
func (x *AlterRoleReq_Password) GetValue() string
func (*AlterRoleReq_Password) ProtoMessage ¶
func (*AlterRoleReq_Password) ProtoMessage()
func (*AlterRoleReq_Password) ProtoReflect ¶
func (x *AlterRoleReq_Password) ProtoReflect() protoreflect.Message
func (*AlterRoleReq_Password) Reset ¶
func (x *AlterRoleReq_Password) Reset()
func (*AlterRoleReq_Password) String ¶
func (x *AlterRoleReq_Password) String() string
type AlterRoleRes ¶
type AlterRoleRes struct {
// contains filtered or unexported fields
}
func (*AlterRoleRes) Descriptor
deprecated
func (*AlterRoleRes) Descriptor() ([]byte, []int)
Deprecated: Use AlterRoleRes.ProtoReflect.Descriptor instead.
func (*AlterRoleRes) ProtoMessage ¶
func (*AlterRoleRes) ProtoMessage()
func (*AlterRoleRes) ProtoReflect ¶
func (x *AlterRoleRes) ProtoReflect() protoreflect.Message
func (*AlterRoleRes) Reset ¶
func (x *AlterRoleRes) Reset()
func (*AlterRoleRes) String ¶
func (x *AlterRoleRes) String() string
type CreateDBReq ¶
type CreateDBReq struct { Db string `protobuf:"bytes,20,opt,name=db,proto3" json:"db,omitempty" toml:"db,omitempty" mapstructure:"db,omitempty"` User string `protobuf:"bytes,21,opt,name=user,proto3" json:"user,omitempty" toml:"user,omitempty" mapstructure:"user,omitempty"` // contains filtered or unexported fields }
func (*CreateDBReq) Descriptor
deprecated
func (*CreateDBReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateDBReq.ProtoReflect.Descriptor instead.
func (*CreateDBReq) GetDb ¶
func (x *CreateDBReq) GetDb() string
func (*CreateDBReq) GetUser ¶
func (x *CreateDBReq) GetUser() string
func (*CreateDBReq) ProtoMessage ¶
func (*CreateDBReq) ProtoMessage()
func (*CreateDBReq) ProtoReflect ¶
func (x *CreateDBReq) ProtoReflect() protoreflect.Message
func (*CreateDBReq) Reset ¶
func (x *CreateDBReq) Reset()
func (*CreateDBReq) String ¶
func (x *CreateDBReq) String() string
type CreateDBRes ¶
type CreateDBRes struct {
// contains filtered or unexported fields
}
func (*CreateDBRes) Descriptor
deprecated
func (*CreateDBRes) Descriptor() ([]byte, []int)
Deprecated: Use CreateDBRes.ProtoReflect.Descriptor instead.
func (*CreateDBRes) ProtoMessage ¶
func (*CreateDBRes) ProtoMessage()
func (*CreateDBRes) ProtoReflect ¶
func (x *CreateDBRes) ProtoReflect() protoreflect.Message
func (*CreateDBRes) Reset ¶
func (x *CreateDBRes) Reset()
func (*CreateDBRes) String ¶
func (x *CreateDBRes) String() string
type CreateExtensionReq ¶
type CreateExtensionReq struct { Db string `protobuf:"bytes,20,opt,name=db,proto3" json:"db,omitempty" toml:"db,omitempty" mapstructure:"db,omitempty"` Ext string `protobuf:"bytes,21,opt,name=ext,proto3" json:"ext,omitempty" toml:"ext,omitempty" mapstructure:"ext,omitempty"` // contains filtered or unexported fields }
func (*CreateExtensionReq) Descriptor
deprecated
func (*CreateExtensionReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateExtensionReq.ProtoReflect.Descriptor instead.
func (*CreateExtensionReq) GetDb ¶
func (x *CreateExtensionReq) GetDb() string
func (*CreateExtensionReq) GetExt ¶
func (x *CreateExtensionReq) GetExt() string
func (*CreateExtensionReq) ProtoMessage ¶
func (*CreateExtensionReq) ProtoMessage()
func (*CreateExtensionReq) ProtoReflect ¶
func (x *CreateExtensionReq) ProtoReflect() protoreflect.Message
func (*CreateExtensionReq) Reset ¶
func (x *CreateExtensionReq) Reset()
func (*CreateExtensionReq) String ¶
func (x *CreateExtensionReq) String() string
type CreateExtensionRes ¶
type CreateExtensionRes struct {
// contains filtered or unexported fields
}
func (*CreateExtensionRes) Descriptor
deprecated
func (*CreateExtensionRes) Descriptor() ([]byte, []int)
Deprecated: Use CreateExtensionRes.ProtoReflect.Descriptor instead.
func (*CreateExtensionRes) ProtoMessage ¶
func (*CreateExtensionRes) ProtoMessage()
func (*CreateExtensionRes) ProtoReflect ¶
func (x *CreateExtensionRes) ProtoReflect() protoreflect.Message
func (*CreateExtensionRes) Reset ¶
func (x *CreateExtensionRes) Reset()
func (*CreateExtensionRes) String ¶
func (x *CreateExtensionRes) String() string
type DeploySqitchReq ¶
type DeploySqitchReq struct { Db string `protobuf:"bytes,20,opt,name=db,proto3" json:"db,omitempty" toml:"db,omitempty" mapstructure:"db,omitempty"` Dir string `protobuf:"bytes,21,opt,name=dir,proto3" json:"dir,omitempty" toml:"dir,omitempty" mapstructure:"dir,omitempty"` User string `protobuf:"bytes,22,opt,name=user,proto3" json:"user,omitempty" toml:"user,omitempty" mapstructure:"user,omitempty"` // contains filtered or unexported fields }
func (*DeploySqitchReq) Descriptor
deprecated
func (*DeploySqitchReq) Descriptor() ([]byte, []int)
Deprecated: Use DeploySqitchReq.ProtoReflect.Descriptor instead.
func (*DeploySqitchReq) GetDb ¶
func (x *DeploySqitchReq) GetDb() string
func (*DeploySqitchReq) GetDir ¶
func (x *DeploySqitchReq) GetDir() string
func (*DeploySqitchReq) GetUser ¶
func (x *DeploySqitchReq) GetUser() string
func (*DeploySqitchReq) ProtoMessage ¶
func (*DeploySqitchReq) ProtoMessage()
func (*DeploySqitchReq) ProtoReflect ¶
func (x *DeploySqitchReq) ProtoReflect() protoreflect.Message
func (*DeploySqitchReq) Reset ¶
func (x *DeploySqitchReq) Reset()
func (*DeploySqitchReq) String ¶
func (x *DeploySqitchReq) String() string
type DeploySqitchRes ¶
type DeploySqitchRes struct {
// contains filtered or unexported fields
}
func (*DeploySqitchRes) Descriptor
deprecated
func (*DeploySqitchRes) Descriptor() ([]byte, []int)
Deprecated: Use DeploySqitchRes.ProtoReflect.Descriptor instead.
func (*DeploySqitchRes) ProtoMessage ¶
func (*DeploySqitchRes) ProtoMessage()
func (*DeploySqitchRes) ProtoReflect ¶
func (x *DeploySqitchRes) ProtoReflect() protoreflect.Message
func (*DeploySqitchRes) Reset ¶
func (x *DeploySqitchRes) Reset()
func (*DeploySqitchRes) String ¶
func (x *DeploySqitchRes) String() string
type DropTablesReq ¶
type DropTablesReq struct { Db string `protobuf:"bytes,20,opt,name=db,proto3" json:"db,omitempty" toml:"db,omitempty" mapstructure:"db,omitempty"` Tables []string `protobuf:"bytes,21,rep,name=tables,proto3" json:"tables,omitempty" toml:"tables,omitempty" mapstructure:"tables,omitempty"` Cascade bool `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DropTablesReq) Descriptor
deprecated
func (*DropTablesReq) Descriptor() ([]byte, []int)
Deprecated: Use DropTablesReq.ProtoReflect.Descriptor instead.
func (*DropTablesReq) GetCascade ¶
func (x *DropTablesReq) GetCascade() bool
func (*DropTablesReq) GetDb ¶
func (x *DropTablesReq) GetDb() string
func (*DropTablesReq) GetTables ¶
func (x *DropTablesReq) GetTables() []string
func (*DropTablesReq) ProtoMessage ¶
func (*DropTablesReq) ProtoMessage()
func (*DropTablesReq) ProtoReflect ¶
func (x *DropTablesReq) ProtoReflect() protoreflect.Message
func (*DropTablesReq) Reset ¶
func (x *DropTablesReq) Reset()
func (*DropTablesReq) String ¶
func (x *DropTablesReq) String() string
type DropTablesRes ¶
type DropTablesRes struct {
// contains filtered or unexported fields
}
func (*DropTablesRes) Descriptor
deprecated
func (*DropTablesRes) Descriptor() ([]byte, []int)
Deprecated: Use DropTablesRes.ProtoReflect.Descriptor instead.
func (*DropTablesRes) ProtoMessage ¶
func (*DropTablesRes) ProtoMessage()
func (*DropTablesRes) ProtoReflect ¶
func (x *DropTablesRes) ProtoReflect() protoreflect.Message
func (*DropTablesRes) Reset ¶
func (x *DropTablesRes) Reset()
func (*DropTablesRes) String ¶
func (x *DropTablesRes) String() string
type ErrorDetails ¶
type ErrorDetails struct { Code ErrorDetails_Codes `` /* 170-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ErrorDetails) Descriptor
deprecated
func (*ErrorDetails) Descriptor() ([]byte, []int)
Deprecated: Use ErrorDetails.ProtoReflect.Descriptor instead.
func (*ErrorDetails) GetCode ¶
func (x *ErrorDetails) GetCode() ErrorDetails_Codes
func (*ErrorDetails) ProtoMessage ¶
func (*ErrorDetails) ProtoMessage()
func (*ErrorDetails) ProtoReflect ¶
func (x *ErrorDetails) ProtoReflect() protoreflect.Message
func (*ErrorDetails) Reset ¶
func (x *ErrorDetails) Reset()
func (*ErrorDetails) String ¶
func (x *ErrorDetails) String() string
type ErrorDetails_Codes ¶
type ErrorDetails_Codes int32
const (
ErrorDetails_SRC_DB_MISSING ErrorDetails_Codes = 0
)
func (ErrorDetails_Codes) Descriptor ¶
func (ErrorDetails_Codes) Descriptor() protoreflect.EnumDescriptor
func (ErrorDetails_Codes) Enum ¶
func (x ErrorDetails_Codes) Enum() *ErrorDetails_Codes
func (ErrorDetails_Codes) EnumDescriptor
deprecated
func (ErrorDetails_Codes) EnumDescriptor() ([]byte, []int)
Deprecated: Use ErrorDetails_Codes.Descriptor instead.
func (ErrorDetails_Codes) Number ¶
func (x ErrorDetails_Codes) Number() protoreflect.EnumNumber
func (ErrorDetails_Codes) String ¶
func (x ErrorDetails_Codes) String() string
func (ErrorDetails_Codes) Type ¶
func (ErrorDetails_Codes) Type() protoreflect.EnumType
type MigrateTablesReq ¶
type MigrateTablesReq struct { FromDb string `` /* 138-byte string literal not displayed */ ToDb string `` /* 128-byte string literal not displayed */ Table []string `protobuf:"bytes,22,rep,name=table,proto3" json:"table,omitempty" toml:"table,omitempty" mapstructure:"table,omitempty"` ImportUser string `` /* 158-byte string literal not displayed */ FailIfSrcDbMissing bool `` /* 211-byte string literal not displayed */ SkipDbCreate bool `` /* 173-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MigrateTablesReq) Descriptor
deprecated
func (*MigrateTablesReq) Descriptor() ([]byte, []int)
Deprecated: Use MigrateTablesReq.ProtoReflect.Descriptor instead.
func (*MigrateTablesReq) GetFailIfSrcDbMissing ¶
func (x *MigrateTablesReq) GetFailIfSrcDbMissing() bool
func (*MigrateTablesReq) GetFromDb ¶
func (x *MigrateTablesReq) GetFromDb() string
func (*MigrateTablesReq) GetImportUser ¶
func (x *MigrateTablesReq) GetImportUser() string
func (*MigrateTablesReq) GetSkipDbCreate ¶
func (x *MigrateTablesReq) GetSkipDbCreate() bool
func (*MigrateTablesReq) GetTable ¶
func (x *MigrateTablesReq) GetTable() []string
func (*MigrateTablesReq) GetToDb ¶
func (x *MigrateTablesReq) GetToDb() string
func (*MigrateTablesReq) ProtoMessage ¶
func (*MigrateTablesReq) ProtoMessage()
func (*MigrateTablesReq) ProtoReflect ¶
func (x *MigrateTablesReq) ProtoReflect() protoreflect.Message
func (*MigrateTablesReq) Reset ¶
func (x *MigrateTablesReq) Reset()
func (*MigrateTablesReq) String ¶
func (x *MigrateTablesReq) String() string
type MigrateTablesRes ¶
type MigrateTablesRes struct {
// contains filtered or unexported fields
}
func (*MigrateTablesRes) Descriptor
deprecated
func (*MigrateTablesRes) Descriptor() ([]byte, []int)
Deprecated: Use MigrateTablesRes.ProtoReflect.Descriptor instead.
func (*MigrateTablesRes) ProtoMessage ¶
func (*MigrateTablesRes) ProtoMessage()
func (*MigrateTablesRes) ProtoReflect ¶
func (x *MigrateTablesRes) ProtoReflect() protoreflect.Message
func (*MigrateTablesRes) Reset ¶
func (x *MigrateTablesRes) Reset()
func (*MigrateTablesRes) String ¶
func (x *MigrateTablesRes) String() string
type PGSidecarServiceClient ¶
type PGSidecarServiceClient interface { MigrateTables(ctx context.Context, in *MigrateTablesReq, opts ...grpc.CallOption) (*MigrateTablesRes, error) RenameDB(ctx context.Context, in *RenameDBReq, opts ...grpc.CallOption) (*RenameDBRes, error) CreateDB(ctx context.Context, in *CreateDBReq, opts ...grpc.CallOption) (*CreateDBRes, error) CreateExtension(ctx context.Context, in *CreateExtensionReq, opts ...grpc.CallOption) (*CreateExtensionRes, error) DeploySqitch(ctx context.Context, in *DeploySqitchReq, opts ...grpc.CallOption) (*DeploySqitchRes, error) SetPublicSchemaRole(ctx context.Context, in *SetPublicSchemaRoleReq, opts ...grpc.CallOption) (*SetPublicSchemaRoleRes, error) AlterRole(ctx context.Context, in *AlterRoleReq, opts ...grpc.CallOption) (*AlterRoleRes, error) DropTables(ctx context.Context, in *DropTablesReq, opts ...grpc.CallOption) (*DropTablesRes, error) }
PGSidecarServiceClient is the client API for PGSidecarService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPGSidecarServiceClient ¶
func NewPGSidecarServiceClient(cc grpc.ClientConnInterface) PGSidecarServiceClient
type PGSidecarServiceServer ¶
type PGSidecarServiceServer interface { MigrateTables(context.Context, *MigrateTablesReq) (*MigrateTablesRes, error) RenameDB(context.Context, *RenameDBReq) (*RenameDBRes, error) CreateDB(context.Context, *CreateDBReq) (*CreateDBRes, error) CreateExtension(context.Context, *CreateExtensionReq) (*CreateExtensionRes, error) DeploySqitch(context.Context, *DeploySqitchReq) (*DeploySqitchRes, error) SetPublicSchemaRole(context.Context, *SetPublicSchemaRoleReq) (*SetPublicSchemaRoleRes, error) AlterRole(context.Context, *AlterRoleReq) (*AlterRoleRes, error) DropTables(context.Context, *DropTablesReq) (*DropTablesRes, error) }
PGSidecarServiceServer is the server API for PGSidecarService service.
type RenameDBReq ¶
type RenameDBReq struct { FromDb string `` /* 138-byte string literal not displayed */ ToDb string `` /* 128-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RenameDBReq) Descriptor
deprecated
func (*RenameDBReq) Descriptor() ([]byte, []int)
Deprecated: Use RenameDBReq.ProtoReflect.Descriptor instead.
func (*RenameDBReq) GetFromDb ¶
func (x *RenameDBReq) GetFromDb() string
func (*RenameDBReq) GetToDb ¶
func (x *RenameDBReq) GetToDb() string
func (*RenameDBReq) ProtoMessage ¶
func (*RenameDBReq) ProtoMessage()
func (*RenameDBReq) ProtoReflect ¶
func (x *RenameDBReq) ProtoReflect() protoreflect.Message
func (*RenameDBReq) Reset ¶
func (x *RenameDBReq) Reset()
func (*RenameDBReq) String ¶
func (x *RenameDBReq) String() string
type RenameDBRes ¶
type RenameDBRes struct {
// contains filtered or unexported fields
}
func (*RenameDBRes) Descriptor
deprecated
func (*RenameDBRes) Descriptor() ([]byte, []int)
Deprecated: Use RenameDBRes.ProtoReflect.Descriptor instead.
func (*RenameDBRes) ProtoMessage ¶
func (*RenameDBRes) ProtoMessage()
func (*RenameDBRes) ProtoReflect ¶
func (x *RenameDBRes) ProtoReflect() protoreflect.Message
func (*RenameDBRes) Reset ¶
func (x *RenameDBRes) Reset()
func (*RenameDBRes) String ¶
func (x *RenameDBRes) String() string
type SetPublicSchemaRoleReq ¶
type SetPublicSchemaRoleReq struct { Role string `protobuf:"bytes,20,opt,name=role,proto3" json:"role,omitempty" toml:"role,omitempty" mapstructure:"role,omitempty"` Db string `protobuf:"bytes,21,opt,name=db,proto3" json:"db,omitempty" toml:"db,omitempty" mapstructure:"db,omitempty"` // contains filtered or unexported fields }
func (*SetPublicSchemaRoleReq) Descriptor
deprecated
func (*SetPublicSchemaRoleReq) Descriptor() ([]byte, []int)
Deprecated: Use SetPublicSchemaRoleReq.ProtoReflect.Descriptor instead.
func (*SetPublicSchemaRoleReq) GetDb ¶
func (x *SetPublicSchemaRoleReq) GetDb() string
func (*SetPublicSchemaRoleReq) GetRole ¶
func (x *SetPublicSchemaRoleReq) GetRole() string
func (*SetPublicSchemaRoleReq) ProtoMessage ¶
func (*SetPublicSchemaRoleReq) ProtoMessage()
func (*SetPublicSchemaRoleReq) ProtoReflect ¶
func (x *SetPublicSchemaRoleReq) ProtoReflect() protoreflect.Message
func (*SetPublicSchemaRoleReq) Reset ¶
func (x *SetPublicSchemaRoleReq) Reset()
func (*SetPublicSchemaRoleReq) String ¶
func (x *SetPublicSchemaRoleReq) String() string
type SetPublicSchemaRoleRes ¶
type SetPublicSchemaRoleRes struct {
// contains filtered or unexported fields
}
func (*SetPublicSchemaRoleRes) Descriptor
deprecated
func (*SetPublicSchemaRoleRes) Descriptor() ([]byte, []int)
Deprecated: Use SetPublicSchemaRoleRes.ProtoReflect.Descriptor instead.
func (*SetPublicSchemaRoleRes) ProtoMessage ¶
func (*SetPublicSchemaRoleRes) ProtoMessage()
func (*SetPublicSchemaRoleRes) ProtoReflect ¶
func (x *SetPublicSchemaRoleRes) ProtoReflect() protoreflect.Message
func (*SetPublicSchemaRoleRes) Reset ¶
func (x *SetPublicSchemaRoleRes) Reset()
func (*SetPublicSchemaRoleRes) String ¶
func (x *SetPublicSchemaRoleRes) String() string
type UnimplementedPGSidecarServiceServer ¶
type UnimplementedPGSidecarServiceServer struct { }
UnimplementedPGSidecarServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedPGSidecarServiceServer) AlterRole ¶
func (*UnimplementedPGSidecarServiceServer) AlterRole(context.Context, *AlterRoleReq) (*AlterRoleRes, error)
func (*UnimplementedPGSidecarServiceServer) CreateDB ¶
func (*UnimplementedPGSidecarServiceServer) CreateDB(context.Context, *CreateDBReq) (*CreateDBRes, error)
func (*UnimplementedPGSidecarServiceServer) CreateExtension ¶
func (*UnimplementedPGSidecarServiceServer) CreateExtension(context.Context, *CreateExtensionReq) (*CreateExtensionRes, error)
func (*UnimplementedPGSidecarServiceServer) DeploySqitch ¶
func (*UnimplementedPGSidecarServiceServer) DeploySqitch(context.Context, *DeploySqitchReq) (*DeploySqitchRes, error)
func (*UnimplementedPGSidecarServiceServer) DropTables ¶
func (*UnimplementedPGSidecarServiceServer) DropTables(context.Context, *DropTablesReq) (*DropTablesRes, error)
func (*UnimplementedPGSidecarServiceServer) MigrateTables ¶
func (*UnimplementedPGSidecarServiceServer) MigrateTables(context.Context, *MigrateTablesReq) (*MigrateTablesRes, error)
func (*UnimplementedPGSidecarServiceServer) RenameDB ¶
func (*UnimplementedPGSidecarServiceServer) RenameDB(context.Context, *RenameDBReq) (*RenameDBRes, error)
func (*UnimplementedPGSidecarServiceServer) SetPublicSchemaRole ¶
func (*UnimplementedPGSidecarServiceServer) SetPublicSchemaRole(context.Context, *SetPublicSchemaRoleReq) (*SetPublicSchemaRoleRes, error)