internal

package
v0.0.18 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2023 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ColumnType_name = map[int32]string{
		0:  "INVALID",
		1:  "BOOL",
		2:  "SMALLINT",
		3:  "INT",
		4:  "BIGINT",
		5:  "FLOAT",
		6:  "UUID",
		7:  "STRING",
		8:  "BYTE_ARRAY",
		9:  "STRING_ARRAY",
		10: "INT_ARRAY",
		11: "TIMESTAMP",
		12: "JSON",
		13: "UUID_ARRAY",
		14: "INET",
		15: "INET_ARRAY",
		16: "CIDR",
		17: "CIDR_ARRAY",
		18: "MAC_ADDR",
		19: "MAC_ADDR_ARRAY",
	}
	ColumnType_value = map[string]int32{
		"INVALID":        0,
		"BOOL":           1,
		"SMALLINT":       2,
		"INT":            3,
		"BIGINT":         4,
		"FLOAT":          5,
		"UUID":           6,
		"STRING":         7,
		"BYTE_ARRAY":     8,
		"STRING_ARRAY":   9,
		"INT_ARRAY":      10,
		"TIMESTAMP":      11,
		"JSON":           12,
		"UUID_ARRAY":     13,
		"INET":           14,
		"INET_ARRAY":     15,
		"CIDR":           16,
		"CIDR_ARRAY":     17,
		"MAC_ADDR":       18,
		"MAC_ADDR_ARRAY": 19,
	}
)

Enum value maps for ColumnType.

View Source 
var (
	ConstraintType_name = map[int32]string{
		0: "PRIMARY_KEY",
		1: "FOREIGN_KEY",
	}
	ConstraintType_value = map[string]int32{
		"PRIMARY_KEY": 0,
		"FOREIGN_KEY": 1,
	}
)

Enum value maps for ConstraintType.

View Source 
var (
	StorageType_name = map[int32]string{
		0: "POSTGRESQL",
		1: "MYSQL",
	}
	StorageType_value = map[string]int32{
		"POSTGRESQL": 0,
		"MYSQL":      1,
	}
)

Enum value maps for StorageType.

View Source 
var (
	Diagnostic_DiagnosticLevel_name = map[int32]string{
		0: "DiagnosisLevelTrace",
		1: "DiagnosisLevelDebug",
		2: "DiagnosisLevelInfo",
		3: "DiagnosisLevelWarn",
		4: "DiagnosisLevelError",
		5: "DiagnosisLevelFatal",
	}
	Diagnostic_DiagnosticLevel_value = map[string]int32{
		"DiagnosisLevelTrace": 0,
		"DiagnosisLevelDebug": 1,
		"DiagnosisLevelInfo":  2,
		"DiagnosisLevelWarn":  3,
		"DiagnosisLevelError": 4,
		"DiagnosisLevelFatal": 5,
	}
)

Enum value maps for Diagnostic_DiagnosticLevel.

View Source 
var File_grpc_internal_provider_proto protoreflect.FileDescriptor
View Source 
var Provider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Provider",
	HandlerType: (*ProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _Provider_Init_Handler,
		},
		{
			MethodName: "GetProviderInformation",
			Handler:    _Provider_GetProviderInformation_Handler,
		},
		{
			MethodName: "GetProviderConfig",
			Handler:    _Provider_GetProviderConfig_Handler,
		},
		{
			MethodName: "SetProviderConfig",
			Handler:    _Provider_SetProviderConfig_Handler,
		},
		{
			MethodName: "DropTableAll",
			Handler:    _Provider_DropTableAll_Handler,
		},
		{
			MethodName: "CreateAllTables",
			Handler:    _Provider_CreateAllTables_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PullTables",
			Handler:       _Provider_PullTables_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "grpc/internal/provider.proto",
}

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

Functions

func RegisterProviderServer 

func RegisterProviderServer(s grpc.ServiceRegistrar, srv ProviderServer)

Types

type CheckConfig 

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

--------------------------------------------------------------------------------------------------------------------

func (*CheckConfig) Descriptor deprecated 

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

Deprecated: Use CheckConfig.ProtoReflect.Descriptor instead.

func (*CheckConfig) ProtoMessage 

func (*CheckConfig) ProtoMessage()

func (*CheckConfig) ProtoReflect 

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

func (*CheckConfig) Reset 

func (x *CheckConfig) Reset()

func (*CheckConfig) String 

func (x *CheckConfig) String() string

type CheckConfig_Request 

type CheckConfig_Request struct {
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckConfig_Request) Descriptor deprecated 

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

Deprecated: Use CheckConfig_Request.ProtoReflect.Descriptor instead.

func (*CheckConfig_Request) GetConfig 

func (x *CheckConfig_Request) GetConfig() string

func (*CheckConfig_Request) ProtoMessage 

func (*CheckConfig_Request) ProtoMessage()

func (*CheckConfig_Request) ProtoReflect 

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

func (*CheckConfig_Request) Reset 

func (x *CheckConfig_Request) Reset()

func (*CheckConfig_Request) String 

func (x *CheckConfig_Request) String() string

type CheckConfig_Response 

type CheckConfig_Response struct {
	Diagnostics []*Diagnostic `protobuf:"bytes,1,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckConfig_Response) Descriptor deprecated 

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

Deprecated: Use CheckConfig_Response.ProtoReflect.Descriptor instead.

func (*CheckConfig_Response) GetDiagnostics 

func (x *CheckConfig_Response) GetDiagnostics() []*Diagnostic

func (*CheckConfig_Response) ProtoMessage 

func (*CheckConfig_Response) ProtoMessage()

func (*CheckConfig_Response) ProtoReflect 

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

func (*CheckConfig_Response) Reset 

func (x *CheckConfig_Response) Reset()

func (*CheckConfig_Response) String 

func (x *CheckConfig_Response) String() string

type Column 

type Column struct {
	Name        string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        ColumnType `protobuf:"varint,2,opt,name=type,proto3,enum=proto.ColumnType" json:"type,omitempty"`
	Description string     `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetDescription 

func (x *Column) GetDescription() string

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetType 

func (x *Column) GetType() ColumnType

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type ColumnMeta 

type ColumnMeta struct {
	Resolver     *ResolverMeta `protobuf:"bytes,1,opt,name=resolver,proto3" json:"resolver,omitempty"`
	IgnoreExists bool          `protobuf:"varint,2,opt,name=ignore_exists,json=ignoreExists,proto3" json:"ignore_exists,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnMeta) Descriptor deprecated 

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

Deprecated: Use ColumnMeta.ProtoReflect.Descriptor instead.

func (*ColumnMeta) GetIgnoreExists 

func (x *ColumnMeta) GetIgnoreExists() bool

func (*ColumnMeta) GetResolver 

func (x *ColumnMeta) GetResolver() *ResolverMeta

func (*ColumnMeta) ProtoMessage 

func (*ColumnMeta) ProtoMessage()

func (*ColumnMeta) ProtoReflect 

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

func (*ColumnMeta) Reset 

func (x *ColumnMeta) Reset()

func (*ColumnMeta) String 

func (x *ColumnMeta) String() string

type ColumnType 

type ColumnType int32
const (
	ColumnType_INVALID        ColumnType = 0
	ColumnType_BOOL           ColumnType = 1
	ColumnType_SMALLINT       ColumnType = 2
	ColumnType_INT            ColumnType = 3
	ColumnType_BIGINT         ColumnType = 4
	ColumnType_FLOAT          ColumnType = 5
	ColumnType_UUID           ColumnType = 6
	ColumnType_STRING         ColumnType = 7
	ColumnType_BYTE_ARRAY     ColumnType = 8
	ColumnType_STRING_ARRAY   ColumnType = 9
	ColumnType_INT_ARRAY      ColumnType = 10
	ColumnType_TIMESTAMP      ColumnType = 11
	ColumnType_JSON           ColumnType = 12
	ColumnType_UUID_ARRAY     ColumnType = 13
	ColumnType_INET           ColumnType = 14
	ColumnType_INET_ARRAY     ColumnType = 15
	ColumnType_CIDR           ColumnType = 16
	ColumnType_CIDR_ARRAY     ColumnType = 17
	ColumnType_MAC_ADDR       ColumnType = 18
	ColumnType_MAC_ADDR_ARRAY ColumnType = 19
)

func (ColumnType) Descriptor 

func (ColumnType) Descriptor() protoreflect.EnumDescriptor

func (ColumnType) Enum 

func (x ColumnType) Enum() *ColumnType

func (ColumnType) EnumDescriptor deprecated 

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

Deprecated: Use ColumnType.Descriptor instead.

func (ColumnType) Number 

func (x ColumnType) Number() protoreflect.EnumNumber

func (ColumnType) String 

func (x ColumnType) String() string

func (ColumnType) Type 

func (ColumnType) Type() protoreflect.EnumType

type Constraint 

type Constraint struct {
	Type      ConstraintType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.ConstraintType" json:"type,omitempty"`
	Columns   []string       `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	TableName string         `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Constraint) Descriptor deprecated 

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

Deprecated: Use Constraint.ProtoReflect.Descriptor instead.

func (*Constraint) GetColumns 

func (x *Constraint) GetColumns() []string

func (*Constraint) GetTableName 

func (x *Constraint) GetTableName() string

func (*Constraint) GetType 

func (x *Constraint) GetType() ConstraintType

func (*Constraint) ProtoMessage 

func (*Constraint) ProtoMessage()

func (*Constraint) ProtoReflect 

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

func (*Constraint) Reset 

func (x *Constraint) Reset()

func (*Constraint) String 

func (x *Constraint) String() string

type ConstraintType 

type ConstraintType int32
const (
	ConstraintType_PRIMARY_KEY ConstraintType = 0
	ConstraintType_FOREIGN_KEY ConstraintType = 1
)

func (ConstraintType) Descriptor 

func (ConstraintType) Descriptor() protoreflect.EnumDescriptor

func (ConstraintType) Enum 

func (x ConstraintType) Enum() *ConstraintType

func (ConstraintType) EnumDescriptor deprecated 

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

Deprecated: Use ConstraintType.Descriptor instead.

func (ConstraintType) Number 

func (x ConstraintType) Number() protoreflect.EnumNumber

func (ConstraintType) String 

func (x ConstraintType) String() string

func (ConstraintType) Type 

func (ConstraintType) Type() protoreflect.EnumType

type CreateAllTables 

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

func (*CreateAllTables) Descriptor deprecated 

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

Deprecated: Use CreateAllTables.ProtoReflect.Descriptor instead.

func (*CreateAllTables) ProtoMessage 

func (*CreateAllTables) ProtoMessage()

func (*CreateAllTables) ProtoReflect 

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

func (*CreateAllTables) Reset 

func (x *CreateAllTables) Reset()

func (*CreateAllTables) String 

func (x *CreateAllTables) String() string

type CreateAllTables_Request 

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

func (*CreateAllTables_Request) Descriptor deprecated 

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

Deprecated: Use CreateAllTables_Request.ProtoReflect.Descriptor instead.

func (*CreateAllTables_Request) ProtoMessage 

func (*CreateAllTables_Request) ProtoMessage()

func (*CreateAllTables_Request) ProtoReflect 

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

func (*CreateAllTables_Request) Reset 

func (x *CreateAllTables_Request) Reset()

func (*CreateAllTables_Request) String 

func (x *CreateAllTables_Request) String() string

type CreateAllTables_Response 

type CreateAllTables_Response struct {
	Diagnostics []*Diagnostic `protobuf:"bytes,1,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAllTables_Response) Descriptor deprecated 

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

Deprecated: Use CreateAllTables_Response.ProtoReflect.Descriptor instead.

func (*CreateAllTables_Response) GetDiagnostics 

func (x *CreateAllTables_Response) GetDiagnostics() []*Diagnostic

func (*CreateAllTables_Response) ProtoMessage 

func (*CreateAllTables_Response) ProtoMessage()

func (*CreateAllTables_Response) ProtoReflect 

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

func (*CreateAllTables_Response) Reset 

func (x *CreateAllTables_Response) Reset()

func (*CreateAllTables_Response) String 

func (x *CreateAllTables_Response) String() string

type Diagnostic 

type Diagnostic struct {
	DiagnosticLevel Diagnostic_DiagnosticLevel `protobuf:"varint,1,opt,name=diagnosticLevel,proto3,enum=proto.Diagnostic_DiagnosticLevel" json:"diagnosticLevel,omitempty"`
	Content         string                     `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*Diagnostic) Descriptor deprecated 

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

Deprecated: Use Diagnostic.ProtoReflect.Descriptor instead.

func (*Diagnostic) GetContent 

func (x *Diagnostic) GetContent() string

func (*Diagnostic) GetDiagnosticLevel 

func (x *Diagnostic) GetDiagnosticLevel() Diagnostic_DiagnosticLevel

func (*Diagnostic) ProtoMessage 

func (*Diagnostic) ProtoMessage()

func (*Diagnostic) ProtoReflect 

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

func (*Diagnostic) Reset 

func (x *Diagnostic) Reset()

func (*Diagnostic) String 

func (x *Diagnostic) String() string

type Diagnostic_DiagnosticLevel 

type Diagnostic_DiagnosticLevel int32
const (
	Diagnostic_DiagnosisLevelTrace Diagnostic_DiagnosticLevel = 0
	Diagnostic_DiagnosisLevelDebug Diagnostic_DiagnosticLevel = 1
	Diagnostic_DiagnosisLevelInfo  Diagnostic_DiagnosticLevel = 2
	Diagnostic_DiagnosisLevelWarn  Diagnostic_DiagnosticLevel = 3
	Diagnostic_DiagnosisLevelError Diagnostic_DiagnosticLevel = 4
	Diagnostic_DiagnosisLevelFatal Diagnostic_DiagnosticLevel = 5
)

func (Diagnostic_DiagnosticLevel) Descriptor 

func (Diagnostic_DiagnosticLevel) Descriptor() protoreflect.EnumDescriptor

func (Diagnostic_DiagnosticLevel) Enum 

func (x Diagnostic_DiagnosticLevel) Enum() *Diagnostic_DiagnosticLevel

func (Diagnostic_DiagnosticLevel) EnumDescriptor deprecated 

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

Deprecated: Use Diagnostic_DiagnosticLevel.Descriptor instead.

func (Diagnostic_DiagnosticLevel) Number 

func (x Diagnostic_DiagnosticLevel) Number() protoreflect.EnumNumber

func (Diagnostic_DiagnosticLevel) String 

func (x Diagnostic_DiagnosticLevel) String() string

func (Diagnostic_DiagnosticLevel) Type 

func (Diagnostic_DiagnosticLevel) Type() protoreflect.EnumType

type DropTableAll 

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

func (*DropTableAll) Descriptor deprecated 

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

Deprecated: Use DropTableAll.ProtoReflect.Descriptor instead.

func (*DropTableAll) ProtoMessage 

func (*DropTableAll) ProtoMessage()

func (*DropTableAll) ProtoReflect 

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

func (*DropTableAll) Reset 

func (x *DropTableAll) Reset()

func (*DropTableAll) String 

func (x *DropTableAll) String() string

type DropTableAll_Request 

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

func (*DropTableAll_Request) Descriptor deprecated 

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

Deprecated: Use DropTableAll_Request.ProtoReflect.Descriptor instead.

func (*DropTableAll_Request) ProtoMessage 

func (*DropTableAll_Request) ProtoMessage()

func (*DropTableAll_Request) ProtoReflect 

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

func (*DropTableAll_Request) Reset 

func (x *DropTableAll_Request) Reset()

func (*DropTableAll_Request) String 

func (x *DropTableAll_Request) String() string

type DropTableAll_Response 

type DropTableAll_Response struct {
	Diagnostics []*Diagnostic `protobuf:"bytes,1,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableAll_Response) Descriptor deprecated 

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

Deprecated: Use DropTableAll_Response.ProtoReflect.Descriptor instead.

func (*DropTableAll_Response) GetDiagnostics 

func (x *DropTableAll_Response) GetDiagnostics() []*Diagnostic

func (*DropTableAll_Response) ProtoMessage 

func (*DropTableAll_Response) ProtoMessage()

func (*DropTableAll_Response) ProtoReflect 

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

func (*DropTableAll_Response) Reset 

func (x *DropTableAll_Response) Reset()

func (*DropTableAll_Response) String 

func (x *DropTableAll_Response) String() string

type GetProviderConfig 

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

func (*GetProviderConfig) Descriptor deprecated 

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

Deprecated: Use GetProviderConfig.ProtoReflect.Descriptor instead.

func (*GetProviderConfig) ProtoMessage 

func (*GetProviderConfig) ProtoMessage()

func (*GetProviderConfig) ProtoReflect 

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

func (*GetProviderConfig) Reset 

func (x *GetProviderConfig) Reset()

func (*GetProviderConfig) String 

func (x *GetProviderConfig) String() string

type GetProviderConfig_Request 

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

func (*GetProviderConfig_Request) Descriptor deprecated 

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

Deprecated: Use GetProviderConfig_Request.ProtoReflect.Descriptor instead.

func (*GetProviderConfig_Request) ProtoMessage 

func (*GetProviderConfig_Request) ProtoMessage()

func (*GetProviderConfig_Request) ProtoReflect 

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

func (*GetProviderConfig_Request) Reset 

func (x *GetProviderConfig_Request) Reset()

func (*GetProviderConfig_Request) String 

func (x *GetProviderConfig_Request) String() string

type GetProviderConfig_Response 

type GetProviderConfig_Response struct {
	Name        string        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version     string        `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Config      string        `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	Diagnostics []*Diagnostic `protobuf:"bytes,4,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProviderConfig_Response) Descriptor deprecated 

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

Deprecated: Use GetProviderConfig_Response.ProtoReflect.Descriptor instead.

func (*GetProviderConfig_Response) GetConfig 

func (x *GetProviderConfig_Response) GetConfig() string

func (*GetProviderConfig_Response) GetDiagnostics 

func (x *GetProviderConfig_Response) GetDiagnostics() []*Diagnostic

func (*GetProviderConfig_Response) GetName 

func (x *GetProviderConfig_Response) GetName() string

func (*GetProviderConfig_Response) GetVersion 

func (x *GetProviderConfig_Response) GetVersion() string

func (*GetProviderConfig_Response) ProtoMessage 

func (*GetProviderConfig_Response) ProtoMessage()

func (*GetProviderConfig_Response) ProtoReflect 

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

func (*GetProviderConfig_Response) Reset 

func (x *GetProviderConfig_Response) Reset()

func (*GetProviderConfig_Response) String 

func (x *GetProviderConfig_Response) String() string

type GetProviderInformation 

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

func (*GetProviderInformation) Descriptor deprecated 

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

Deprecated: Use GetProviderInformation.ProtoReflect.Descriptor instead.

func (*GetProviderInformation) ProtoMessage 

func (*GetProviderInformation) ProtoMessage()

func (*GetProviderInformation) ProtoReflect 

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

func (*GetProviderInformation) Reset 

func (x *GetProviderInformation) Reset()

func (*GetProviderInformation) String 

func (x *GetProviderInformation) String() string

type GetProviderInformation_Request 

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

func (*GetProviderInformation_Request) Descriptor deprecated 

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

Deprecated: Use GetProviderInformation_Request.ProtoReflect.Descriptor instead.

func (*GetProviderInformation_Request) ProtoMessage 

func (*GetProviderInformation_Request) ProtoMessage()

func (*GetProviderInformation_Request) ProtoReflect 

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

func (*GetProviderInformation_Request) Reset 

func (x *GetProviderInformation_Request) Reset()

func (*GetProviderInformation_Request) String 

func (x *GetProviderInformation_Request) String() string

type GetProviderInformation_Response 

type GetProviderInformation_Response struct {
	Name                  string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version               string            `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Tables                map[string]*Table `` /* 153-byte string literal not displayed */
	DefaultConfigTemplate string            `` /* 126-byte string literal not displayed */
	Diagnostics           []*Diagnostic     `protobuf:"bytes,5,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetProviderInformation_Response) Descriptor deprecated 

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

Deprecated: Use GetProviderInformation_Response.ProtoReflect.Descriptor instead.

func (*GetProviderInformation_Response) GetDefaultConfigTemplate 

func (x *GetProviderInformation_Response) GetDefaultConfigTemplate() string

func (*GetProviderInformation_Response) GetDiagnostics 

func (x *GetProviderInformation_Response) GetDiagnostics() []*Diagnostic

func (*GetProviderInformation_Response) GetName 

func (x *GetProviderInformation_Response) GetName() string

func (*GetProviderInformation_Response) GetTables 

func (x *GetProviderInformation_Response) GetTables() map[string]*Table

func (*GetProviderInformation_Response) GetVersion 

func (x *GetProviderInformation_Response) GetVersion() string

func (*GetProviderInformation_Response) ProtoMessage 

func (*GetProviderInformation_Response) ProtoMessage()

func (*GetProviderInformation_Response) ProtoReflect 

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

func (*GetProviderInformation_Response) Reset 

func (x *GetProviderInformation_Response) Reset()

func (*GetProviderInformation_Response) String 

func (x *GetProviderInformation_Response) String() string

type ProviderClient 

type ProviderClient interface {
	Init(ctx context.Context, in *ProviderInit_Request, opts ...grpc.CallOption) (*ProviderInit_Response, error)
	GetProviderInformation(ctx context.Context, in *GetProviderInformation_Request, opts ...grpc.CallOption) (*GetProviderInformation_Response, error)
	GetProviderConfig(ctx context.Context, in *GetProviderConfig_Request, opts ...grpc.CallOption) (*GetProviderConfig_Response, error)
	SetProviderConfig(ctx context.Context, in *SetProviderConfig_Request, opts ...grpc.CallOption) (*SetProviderConfig_Response, error)
	PullTables(ctx context.Context, in *PullTables_Request, opts ...grpc.CallOption) (Provider_PullTablesClient, error)
	DropTableAll(ctx context.Context, in *DropTableAll_Request, opts ...grpc.CallOption) (*DropTableAll_Response, error)
	CreateAllTables(ctx context.Context, in *CreateAllTables_Request, opts ...grpc.CallOption) (*CreateAllTables_Response, error)
}

ProviderClient is the client API for Provider 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 NewProviderClient 

func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient

type ProviderInit 

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

func (*ProviderInit) Descriptor deprecated 

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

Deprecated: Use ProviderInit.ProtoReflect.Descriptor instead.

func (*ProviderInit) ProtoMessage 

func (*ProviderInit) ProtoMessage()

func (*ProviderInit) ProtoReflect 

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

func (*ProviderInit) Reset 

func (x *ProviderInit) Reset()

func (*ProviderInit) String 

func (x *ProviderInit) String() string

type ProviderInit_Request 

type ProviderInit_Request struct {
	Storage        *Storage `protobuf:"bytes,1,opt,name=storage,proto3,oneof" json:"storage,omitempty"`
	Workspace      *string  `protobuf:"bytes,2,opt,name=workspace,proto3,oneof" json:"workspace,omitempty"`
	ProviderConfig *string  `protobuf:"bytes,3,opt,name=provider_config,json=providerConfig,proto3,oneof" json:"provider_config,omitempty"`
	IsInstallInit  *bool    `protobuf:"varint,4,opt,name=is_install_init,json=isInstallInit,proto3,oneof" json:"is_install_init,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderInit_Request) Descriptor deprecated 

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

Deprecated: Use ProviderInit_Request.ProtoReflect.Descriptor instead.

func (*ProviderInit_Request) GetIsInstallInit 

func (x *ProviderInit_Request) GetIsInstallInit() bool

func (*ProviderInit_Request) GetProviderConfig 

func (x *ProviderInit_Request) GetProviderConfig() string

func (*ProviderInit_Request) GetStorage 

func (x *ProviderInit_Request) GetStorage() *Storage

func (*ProviderInit_Request) GetWorkspace 

func (x *ProviderInit_Request) GetWorkspace() string

func (*ProviderInit_Request) ProtoMessage 

func (*ProviderInit_Request) ProtoMessage()

func (*ProviderInit_Request) ProtoReflect 

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

func (*ProviderInit_Request) Reset 

func (x *ProviderInit_Request) Reset()

func (*ProviderInit_Request) String 

func (x *ProviderInit_Request) String() string

type ProviderInit_Response 

type ProviderInit_Response struct {
	Diagnostics []*Diagnostic `protobuf:"bytes,1,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*ProviderInit_Response) Descriptor deprecated 

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

Deprecated: Use ProviderInit_Response.ProtoReflect.Descriptor instead.

func (*ProviderInit_Response) GetDiagnostics 

func (x *ProviderInit_Response) GetDiagnostics() []*Diagnostic

func (*ProviderInit_Response) ProtoMessage 

func (*ProviderInit_Response) ProtoMessage()

func (*ProviderInit_Response) ProtoReflect 

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

func (*ProviderInit_Response) Reset 

func (x *ProviderInit_Response) Reset()

func (*ProviderInit_Response) String 

func (x *ProviderInit_Response) String() string

type ProviderServer 

type ProviderServer interface {
	Init(context.Context, *ProviderInit_Request) (*ProviderInit_Response, error)
	GetProviderInformation(context.Context, *GetProviderInformation_Request) (*GetProviderInformation_Response, error)
	GetProviderConfig(context.Context, *GetProviderConfig_Request) (*GetProviderConfig_Response, error)
	SetProviderConfig(context.Context, *SetProviderConfig_Request) (*SetProviderConfig_Response, error)
	PullTables(*PullTables_Request, Provider_PullTablesServer) error
	DropTableAll(context.Context, *DropTableAll_Request) (*DropTableAll_Response, error)
	CreateAllTables(context.Context, *CreateAllTables_Request) (*CreateAllTables_Response, error)
	// contains filtered or unexported methods
}

ProviderServer is the server API for Provider service. All implementations must embed UnimplementedProviderServer for forward compatibility

type Provider_PullTablesClient 

type Provider_PullTablesClient interface {
	Recv() (*PullTables_Response, error)
	grpc.ClientStream
}

type Provider_PullTablesServer 

type Provider_PullTablesServer interface {
	Send(*PullTables_Response) error
	grpc.ServerStream
}

type PullTables 

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

func (*PullTables) Descriptor deprecated 

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

Deprecated: Use PullTables.ProtoReflect.Descriptor instead.

func (*PullTables) ProtoMessage 

func (*PullTables) ProtoMessage()

func (*PullTables) ProtoReflect 

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

func (*PullTables) Reset 

func (x *PullTables) Reset()

func (*PullTables) String 

func (x *PullTables) String() string

type PullTables_Request 

type PullTables_Request struct {
	Tables        []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	MaxGoroutines uint64   `protobuf:"varint,2,opt,name=max_goroutines,json=maxGoroutines,proto3" json:"max_goroutines,omitempty"`
	Timeout       int64    `protobuf:"varint,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*PullTables_Request) Descriptor deprecated 

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

Deprecated: Use PullTables_Request.ProtoReflect.Descriptor instead.

func (*PullTables_Request) GetMaxGoroutines 

func (x *PullTables_Request) GetMaxGoroutines() uint64

func (*PullTables_Request) GetTables 

func (x *PullTables_Request) GetTables() []string

func (*PullTables_Request) GetTimeout 

func (x *PullTables_Request) GetTimeout() int64

func (*PullTables_Request) ProtoMessage 

func (*PullTables_Request) ProtoMessage()

func (*PullTables_Request) ProtoReflect 

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

func (*PullTables_Request) Reset 

func (x *PullTables_Request) Reset()

func (*PullTables_Request) String 

func (x *PullTables_Request) String() string

type PullTables_Response 

type PullTables_Response struct {

	// map of tables that have finished fetching
	FinishedTables map[string]bool `` /* 192-byte string literal not displayed */
	// Amount of tables collected so far
	TableCount  uint64        `protobuf:"varint,2,opt,name=table_count,json=tableCount,proto3" json:"table_count,omitempty"`
	Table       string        `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	Diagnostics []*Diagnostic `protobuf:"bytes,4,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*PullTables_Response) Descriptor deprecated 

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

Deprecated: Use PullTables_Response.ProtoReflect.Descriptor instead.

func (*PullTables_Response) GetDiagnostics 

func (x *PullTables_Response) GetDiagnostics() []*Diagnostic

func (*PullTables_Response) GetFinishedTables 

func (x *PullTables_Response) GetFinishedTables() map[string]bool

func (*PullTables_Response) GetTable 

func (x *PullTables_Response) GetTable() string

func (*PullTables_Response) GetTableCount 

func (x *PullTables_Response) GetTableCount() uint64

func (*PullTables_Response) ProtoMessage 

func (*PullTables_Response) ProtoMessage()

func (*PullTables_Response) ProtoReflect 

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

func (*PullTables_Response) Reset 

func (x *PullTables_Response) Reset()

func (*PullTables_Response) String 

func (x *PullTables_Response) String() string

type ResolverMeta 

type ResolverMeta struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Builtin bool   `protobuf:"varint,2,opt,name=builtin,proto3" json:"builtin,omitempty"`
	// contains filtered or unexported fields
}

func (*ResolverMeta) Descriptor deprecated 

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

Deprecated: Use ResolverMeta.ProtoReflect.Descriptor instead.

func (*ResolverMeta) GetBuiltin 

func (x *ResolverMeta) GetBuiltin() bool

func (*ResolverMeta) GetName 

func (x *ResolverMeta) GetName() string

func (*ResolverMeta) ProtoMessage 

func (*ResolverMeta) ProtoMessage()

func (*ResolverMeta) ProtoReflect 

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

func (*ResolverMeta) Reset 

func (x *ResolverMeta) Reset()

func (*ResolverMeta) String 

func (x *ResolverMeta) String() string

type SetProviderConfig 

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

func (*SetProviderConfig) Descriptor deprecated 

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

Deprecated: Use SetProviderConfig.ProtoReflect.Descriptor instead.

func (*SetProviderConfig) ProtoMessage 

func (*SetProviderConfig) ProtoMessage()

func (*SetProviderConfig) ProtoReflect 

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

func (*SetProviderConfig) Reset 

func (x *SetProviderConfig) Reset()

func (*SetProviderConfig) String 

func (x *SetProviderConfig) String() string

type SetProviderConfig_Request 

type SetProviderConfig_Request struct {
	Storage        *Storage `protobuf:"bytes,1,opt,name=storage,proto3,oneof" json:"storage,omitempty"`
	ProviderConfig *string  `protobuf:"bytes,2,opt,name=provider_config,json=providerConfig,proto3,oneof" json:"provider_config,omitempty"`
	// contains filtered or unexported fields
}

func (*SetProviderConfig_Request) Descriptor deprecated 

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

Deprecated: Use SetProviderConfig_Request.ProtoReflect.Descriptor instead.

func (*SetProviderConfig_Request) GetProviderConfig 

func (x *SetProviderConfig_Request) GetProviderConfig() string

func (*SetProviderConfig_Request) GetStorage 

func (x *SetProviderConfig_Request) GetStorage() *Storage

func (*SetProviderConfig_Request) ProtoMessage 

func (*SetProviderConfig_Request) ProtoMessage()

func (*SetProviderConfig_Request) ProtoReflect 

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

func (*SetProviderConfig_Request) Reset 

func (x *SetProviderConfig_Request) Reset()

func (*SetProviderConfig_Request) String 

func (x *SetProviderConfig_Request) String() string

type SetProviderConfig_Response 

type SetProviderConfig_Response struct {
	Diagnostics []*Diagnostic `protobuf:"bytes,1,rep,name=diagnostics,proto3" json:"diagnostics,omitempty"`
	// contains filtered or unexported fields
}

func (*SetProviderConfig_Response) Descriptor deprecated 

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

Deprecated: Use SetProviderConfig_Response.ProtoReflect.Descriptor instead.

func (*SetProviderConfig_Response) GetDiagnostics 

func (x *SetProviderConfig_Response) GetDiagnostics() []*Diagnostic

func (*SetProviderConfig_Response) ProtoMessage 

func (*SetProviderConfig_Response) ProtoMessage()

func (*SetProviderConfig_Response) ProtoReflect 

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

func (*SetProviderConfig_Response) Reset 

func (x *SetProviderConfig_Response) Reset()

func (*SetProviderConfig_Response) String 

func (x *SetProviderConfig_Response) String() string

type Storage 

type Storage struct {
	Type           StorageType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.StorageType" json:"type,omitempty"`
	StorageOptions string      `protobuf:"bytes,2,opt,name=storage_options,json=storageOptions,proto3" json:"storage_options,omitempty"`
	// contains filtered or unexported fields
}

func (*Storage) Descriptor deprecated 

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

Deprecated: Use Storage.ProtoReflect.Descriptor instead.

func (*Storage) GetStorageOptions 

func (x *Storage) GetStorageOptions() string

func (*Storage) GetType 

func (x *Storage) GetType() StorageType

func (*Storage) ProtoMessage 

func (*Storage) ProtoMessage()

func (*Storage) ProtoReflect 

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

func (*Storage) Reset 

func (x *Storage) Reset()

func (*Storage) String 

func (x *Storage) String() string

type StorageType 

type StorageType int32
const (
	StorageType_POSTGRESQL StorageType = 0
	StorageType_MYSQL      StorageType = 1
)

func (StorageType) Descriptor 

func (StorageType) Descriptor() protoreflect.EnumDescriptor

func (StorageType) Enum 

func (x StorageType) Enum() *StorageType

func (StorageType) EnumDescriptor deprecated 

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

Deprecated: Use StorageType.Descriptor instead.

func (StorageType) Number 

func (x StorageType) Number() protoreflect.EnumNumber

func (StorageType) String 

func (x StorageType) String() string

func (StorageType) Type 

func (StorageType) Type() protoreflect.EnumType

type Table 

type Table struct {
	Namespace   string    `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TableName   string    `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Description string    `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Columns     []*Column `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	SubTables   []*Table  `protobuf:"bytes,5,rep,name=sub_tables,json=subTables,proto3" json:"sub_tables,omitempty"`
	Version     uint64    `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetColumns 

func (x *Table) GetColumns() []*Column

func (*Table) GetDescription 

func (x *Table) GetDescription() string

func (*Table) GetNamespace 

func (x *Table) GetNamespace() string

func (*Table) GetSubTables 

func (x *Table) GetSubTables() []*Table

func (*Table) GetTableName 

func (x *Table) GetTableName() string

func (*Table) GetVersion 

func (x *Table) GetVersion() uint64

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type UnimplementedProviderServer 

type UnimplementedProviderServer struct {
}

UnimplementedProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedProviderServer) CreateAllTables 

func (UnimplementedProviderServer) CreateAllTables(context.Context, *CreateAllTables_Request) (*CreateAllTables_Response, error)

func (UnimplementedProviderServer) DropTableAll 

func (UnimplementedProviderServer) DropTableAll(context.Context, *DropTableAll_Request) (*DropTableAll_Response, error)

func (UnimplementedProviderServer) GetProviderConfig 

func (UnimplementedProviderServer) GetProviderConfig(context.Context, *GetProviderConfig_Request) (*GetProviderConfig_Response, error)

func (UnimplementedProviderServer) GetProviderInformation 

func (UnimplementedProviderServer) GetProviderInformation(context.Context, *GetProviderInformation_Request) (*GetProviderInformation_Response, error)

func (UnimplementedProviderServer) Init 

func (UnimplementedProviderServer) Init(context.Context, *ProviderInit_Request) (*ProviderInit_Response, error)

func (UnimplementedProviderServer) PullTables 

func (UnimplementedProviderServer) PullTables(*PullTables_Request, Provider_PullTablesServer) error

func (UnimplementedProviderServer) SetProviderConfig 

func (UnimplementedProviderServer) SetProviderConfig(context.Context, *SetProviderConfig_Request) (*SetProviderConfig_Response, error)

type UnsafeProviderServer 

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

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

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.