source

package
v1.20.2 Latest Latest
Warning

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

Go to latest
Published: Jun 19, 2024 License: MPL-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

View Source
const (
	Source_GetName_FullMethodName          = "/cloudquery.source.v2.Source/GetName"
	Source_GetVersion_FullMethodName       = "/cloudquery.source.v2.Source/GetVersion"
	Source_GetTables_FullMethodName        = "/cloudquery.source.v2.Source/GetTables"
	Source_GetMetrics_FullMethodName       = "/cloudquery.source.v2.Source/GetMetrics"
	Source_Init_FullMethodName             = "/cloudquery.source.v2.Source/Init"
	Source_GetDynamicTables_FullMethodName = "/cloudquery.source.v2.Source/GetDynamicTables"
	Source_Sync_FullMethodName             = "/cloudquery.source.v2.Source/Sync"
	Source_GenDocs_FullMethodName          = "/cloudquery.source.v2.Source/GenDocs"
)

Variables

View Source
var (
	GenDocs_FORMAT_name = map[int32]string{
		0: "markdown",
		1: "json",
	}
	GenDocs_FORMAT_value = map[string]int32{
		"markdown": 0,
		"json":     1,
	}
)

Enum value maps for GenDocs_FORMAT.

View Source
var File_plugin_pb_source_v2_source_proto protoreflect.FileDescriptor
View Source
var Source_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloudquery.source.v2.Source",
	HandlerType: (*SourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetName",
			Handler:    _Source_GetName_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Source_GetVersion_Handler,
		},
		{
			MethodName: "GetTables",
			Handler:    _Source_GetTables_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _Source_GetMetrics_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _Source_Init_Handler,
		},
		{
			MethodName: "GetDynamicTables",
			Handler:    _Source_GetDynamicTables_Handler,
		},
		{
			MethodName: "GenDocs",
			Handler:    _Source_GenDocs_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sync",
			Handler:       _Source_Sync_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "plugin-pb/source/v2/source.proto",
}

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

Functions

func RecordToBytes added in v1.3.3

func RecordToBytes(record arrow.Record) ([]byte, error)

func RegisterSourceServer

func RegisterSourceServer(s grpc.ServiceRegistrar, srv SourceServer)

func SchemasToBytes added in v1.3.1

func SchemasToBytes(schemas []*arrow.Schema) ([][]byte, error)

Types

type GenDocs

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

func (*GenDocs) Descriptor deprecated

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

Deprecated: Use GenDocs.ProtoReflect.Descriptor instead.

func (*GenDocs) ProtoMessage

func (*GenDocs) ProtoMessage()

func (*GenDocs) ProtoReflect

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

func (*GenDocs) Reset

func (x *GenDocs) Reset()

func (*GenDocs) String

func (x *GenDocs) String() string

type GenDocs_FORMAT

type GenDocs_FORMAT int32
const (
	GenDocs_markdown GenDocs_FORMAT = 0
	GenDocs_json     GenDocs_FORMAT = 1
)

func (GenDocs_FORMAT) Descriptor

func (GenDocs_FORMAT) Enum

func (x GenDocs_FORMAT) Enum() *GenDocs_FORMAT

func (GenDocs_FORMAT) EnumDescriptor deprecated

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

Deprecated: Use GenDocs_FORMAT.Descriptor instead.

func (GenDocs_FORMAT) Number

func (GenDocs_FORMAT) String

func (x GenDocs_FORMAT) String() string

func (GenDocs_FORMAT) Type

type GenDocs_Request

type GenDocs_Request struct {
	Path   string         `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Format GenDocs_FORMAT `protobuf:"varint,2,opt,name=format,proto3,enum=cloudquery.source.v2.GenDocs_FORMAT" json:"format,omitempty"`
	// contains filtered or unexported fields
}

func (*GenDocs_Request) Descriptor deprecated

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

Deprecated: Use GenDocs_Request.ProtoReflect.Descriptor instead.

func (*GenDocs_Request) GetFormat

func (x *GenDocs_Request) GetFormat() GenDocs_FORMAT

func (*GenDocs_Request) GetPath

func (x *GenDocs_Request) GetPath() string

func (*GenDocs_Request) ProtoMessage

func (*GenDocs_Request) ProtoMessage()

func (*GenDocs_Request) ProtoReflect

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

func (*GenDocs_Request) Reset

func (x *GenDocs_Request) Reset()

func (*GenDocs_Request) String

func (x *GenDocs_Request) String() string

type GenDocs_Response

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

func (*GenDocs_Response) Descriptor deprecated

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

Deprecated: Use GenDocs_Response.ProtoReflect.Descriptor instead.

func (*GenDocs_Response) ProtoMessage

func (*GenDocs_Response) ProtoMessage()

func (*GenDocs_Response) ProtoReflect

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

func (*GenDocs_Response) Reset

func (x *GenDocs_Response) Reset()

func (*GenDocs_Response) String

func (x *GenDocs_Response) String() string

type GetDynamicTables

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

func (*GetDynamicTables) Descriptor deprecated

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

Deprecated: Use GetDynamicTables.ProtoReflect.Descriptor instead.

func (*GetDynamicTables) ProtoMessage

func (*GetDynamicTables) ProtoMessage()

func (*GetDynamicTables) ProtoReflect

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

func (*GetDynamicTables) Reset

func (x *GetDynamicTables) Reset()

func (*GetDynamicTables) String

func (x *GetDynamicTables) String() string

type GetDynamicTables_Request

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

func (*GetDynamicTables_Request) Descriptor deprecated

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

Deprecated: Use GetDynamicTables_Request.ProtoReflect.Descriptor instead.

func (*GetDynamicTables_Request) ProtoMessage

func (*GetDynamicTables_Request) ProtoMessage()

func (*GetDynamicTables_Request) ProtoReflect

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

func (*GetDynamicTables_Request) Reset

func (x *GetDynamicTables_Request) Reset()

func (*GetDynamicTables_Request) String

func (x *GetDynamicTables_Request) String() string

type GetDynamicTables_Response

type GetDynamicTables_Response struct {

	// marshaled []*schema.Table
	Tables [][]byte `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDynamicTables_Response) Descriptor deprecated

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

Deprecated: Use GetDynamicTables_Response.ProtoReflect.Descriptor instead.

func (*GetDynamicTables_Response) GetTables

func (x *GetDynamicTables_Response) GetTables() [][]byte

func (*GetDynamicTables_Response) ProtoMessage

func (*GetDynamicTables_Response) ProtoMessage()

func (*GetDynamicTables_Response) ProtoReflect

func (*GetDynamicTables_Response) Reset

func (x *GetDynamicTables_Response) Reset()

func (*GetDynamicTables_Response) String

func (x *GetDynamicTables_Response) String() string

type GetMetrics

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

func (*GetMetrics) Descriptor deprecated

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

Deprecated: Use GetMetrics.ProtoReflect.Descriptor instead.

func (*GetMetrics) ProtoMessage

func (*GetMetrics) ProtoMessage()

func (*GetMetrics) ProtoReflect

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

func (*GetMetrics) Reset

func (x *GetMetrics) Reset()

func (*GetMetrics) String

func (x *GetMetrics) String() string

type GetMetrics_Request

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

func (*GetMetrics_Request) Descriptor deprecated

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

Deprecated: Use GetMetrics_Request.ProtoReflect.Descriptor instead.

func (*GetMetrics_Request) ProtoMessage

func (*GetMetrics_Request) ProtoMessage()

func (*GetMetrics_Request) ProtoReflect

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

func (*GetMetrics_Request) Reset

func (x *GetMetrics_Request) Reset()

func (*GetMetrics_Request) String

func (x *GetMetrics_Request) String() string

type GetMetrics_Response

type GetMetrics_Response struct {

	// marshalled json of plugins.SourceMetrics
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMetrics_Response) Descriptor deprecated

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

Deprecated: Use GetMetrics_Response.ProtoReflect.Descriptor instead.

func (*GetMetrics_Response) GetMetrics

func (x *GetMetrics_Response) GetMetrics() []byte

func (*GetMetrics_Response) ProtoMessage

func (*GetMetrics_Response) ProtoMessage()

func (*GetMetrics_Response) ProtoReflect

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

func (*GetMetrics_Response) Reset

func (x *GetMetrics_Response) Reset()

func (*GetMetrics_Response) String

func (x *GetMetrics_Response) String() string

type GetName

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

func (*GetName) Descriptor deprecated

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

Deprecated: Use GetName.ProtoReflect.Descriptor instead.

func (*GetName) ProtoMessage

func (*GetName) ProtoMessage()

func (*GetName) ProtoReflect

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

func (*GetName) Reset

func (x *GetName) Reset()

func (*GetName) String

func (x *GetName) String() string

type GetName_Request

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

func (*GetName_Request) Descriptor deprecated

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

Deprecated: Use GetName_Request.ProtoReflect.Descriptor instead.

func (*GetName_Request) ProtoMessage

func (*GetName_Request) ProtoMessage()

func (*GetName_Request) ProtoReflect

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

func (*GetName_Request) Reset

func (x *GetName_Request) Reset()

func (*GetName_Request) String

func (x *GetName_Request) String() string

type GetName_Response

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

func (*GetName_Response) Descriptor deprecated

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

Deprecated: Use GetName_Response.ProtoReflect.Descriptor instead.

func (*GetName_Response) GetName

func (x *GetName_Response) GetName() string

func (*GetName_Response) ProtoMessage

func (*GetName_Response) ProtoMessage()

func (*GetName_Response) ProtoReflect

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

func (*GetName_Response) Reset

func (x *GetName_Response) Reset()

func (*GetName_Response) String

func (x *GetName_Response) String() string

type GetTables

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

func (*GetTables) Descriptor deprecated

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

Deprecated: Use GetTables.ProtoReflect.Descriptor instead.

func (*GetTables) ProtoMessage

func (*GetTables) ProtoMessage()

func (*GetTables) ProtoReflect

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

func (*GetTables) Reset

func (x *GetTables) Reset()

func (*GetTables) String

func (x *GetTables) String() string

type GetTables_Request

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

func (*GetTables_Request) Descriptor deprecated

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

Deprecated: Use GetTables_Request.ProtoReflect.Descriptor instead.

func (*GetTables_Request) ProtoMessage

func (*GetTables_Request) ProtoMessage()

func (*GetTables_Request) ProtoReflect

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

func (*GetTables_Request) Reset

func (x *GetTables_Request) Reset()

func (*GetTables_Request) String

func (x *GetTables_Request) String() string

type GetTables_Response

type GetTables_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"`
	// Marshalled []arrow.Schema
	Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTables_Response) Descriptor deprecated

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

Deprecated: Use GetTables_Response.ProtoReflect.Descriptor instead.

func (*GetTables_Response) GetName

func (x *GetTables_Response) GetName() string

func (*GetTables_Response) GetTables

func (x *GetTables_Response) GetTables() [][]byte

func (*GetTables_Response) GetVersion

func (x *GetTables_Response) GetVersion() string

func (*GetTables_Response) ProtoMessage

func (*GetTables_Response) ProtoMessage()

func (*GetTables_Response) ProtoReflect

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

func (*GetTables_Response) Reset

func (x *GetTables_Response) Reset()

func (*GetTables_Response) String

func (x *GetTables_Response) String() string

type GetVersion

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

func (*GetVersion) Descriptor deprecated

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

Deprecated: Use GetVersion.ProtoReflect.Descriptor instead.

func (*GetVersion) ProtoMessage

func (*GetVersion) ProtoMessage()

func (*GetVersion) ProtoReflect

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

func (*GetVersion) Reset

func (x *GetVersion) Reset()

func (*GetVersion) String

func (x *GetVersion) String() string

type GetVersion_Request

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

func (*GetVersion_Request) Descriptor deprecated

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

Deprecated: Use GetVersion_Request.ProtoReflect.Descriptor instead.

func (*GetVersion_Request) ProtoMessage

func (*GetVersion_Request) ProtoMessage()

func (*GetVersion_Request) ProtoReflect

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

func (*GetVersion_Request) Reset

func (x *GetVersion_Request) Reset()

func (*GetVersion_Request) String

func (x *GetVersion_Request) String() string

type GetVersion_Response

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

func (*GetVersion_Response) Descriptor deprecated

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

Deprecated: Use GetVersion_Response.ProtoReflect.Descriptor instead.

func (*GetVersion_Response) GetVersion

func (x *GetVersion_Response) GetVersion() string

func (*GetVersion_Response) ProtoMessage

func (*GetVersion_Response) ProtoMessage()

func (*GetVersion_Response) ProtoReflect

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

func (*GetVersion_Response) Reset

func (x *GetVersion_Response) Reset()

func (*GetVersion_Response) String

func (x *GetVersion_Response) String() string

type Init

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

func (*Init) Descriptor deprecated

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

Deprecated: Use Init.ProtoReflect.Descriptor instead.

func (*Init) ProtoMessage

func (*Init) ProtoMessage()

func (*Init) ProtoReflect

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

func (*Init) Reset

func (x *Init) Reset()

func (*Init) String

func (x *Init) String() string

type Init_Request

type Init_Request struct {

	// marshaled specs.Source
	Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Init_Request) Descriptor deprecated

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

Deprecated: Use Init_Request.ProtoReflect.Descriptor instead.

func (*Init_Request) GetSpec

func (x *Init_Request) GetSpec() []byte

func (*Init_Request) ProtoMessage

func (*Init_Request) ProtoMessage()

func (*Init_Request) ProtoReflect

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

func (*Init_Request) Reset

func (x *Init_Request) Reset()

func (*Init_Request) String

func (x *Init_Request) String() string

type Init_Response

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

func (*Init_Response) Descriptor deprecated

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

Deprecated: Use Init_Response.ProtoReflect.Descriptor instead.

func (*Init_Response) ProtoMessage

func (*Init_Response) ProtoMessage()

func (*Init_Response) ProtoReflect

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

func (*Init_Response) Reset

func (x *Init_Response) Reset()

func (*Init_Response) String

func (x *Init_Response) String() string

type SourceClient

type SourceClient interface {
	// Get the name of the plugin
	GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error)
	// Get all static tables the source plugin supports
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// Get metrics for the source plugin
	GetMetrics(ctx context.Context, in *GetMetrics_Request, opts ...grpc.CallOption) (*GetMetrics_Response, error)
	// Configure the plugin with the given credentials and mode
	Init(ctx context.Context, in *Init_Request, opts ...grpc.CallOption) (*Init_Response, error)
	// Get all tables the source plugin supports. Must be called after Init
	GetDynamicTables(ctx context.Context, in *GetDynamicTables_Request, opts ...grpc.CallOption) (*GetDynamicTables_Response, error)
	// Start the sync the source plugin
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error)
	// Generate documentation for the source plugin
	GenDocs(ctx context.Context, in *GenDocs_Request, opts ...grpc.CallOption) (*GenDocs_Response, error)
}

SourceClient is the client API for Source 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 NewSourceClient

func NewSourceClient(cc grpc.ClientConnInterface) SourceClient

type SourceServer

type SourceServer interface {
	// Get the name of the plugin
	GetName(context.Context, *GetName_Request) (*GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(context.Context, *GetVersion_Request) (*GetVersion_Response, error)
	// Get all static tables the source plugin supports
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// Get metrics for the source plugin
	GetMetrics(context.Context, *GetMetrics_Request) (*GetMetrics_Response, error)
	// Configure the plugin with the given credentials and mode
	Init(context.Context, *Init_Request) (*Init_Response, error)
	// Get all tables the source plugin supports. Must be called after Init
	GetDynamicTables(context.Context, *GetDynamicTables_Request) (*GetDynamicTables_Response, error)
	// Start the sync the source plugin
	Sync(*Sync_Request, Source_SyncServer) error
	// Generate documentation for the source plugin
	GenDocs(context.Context, *GenDocs_Request) (*GenDocs_Response, error)
	// contains filtered or unexported methods
}

SourceServer is the server API for Source service. All implementations must embed UnimplementedSourceServer for forward compatibility

type Source_SyncClient

type Source_SyncClient interface {
	Recv() (*Sync_Response, error)
	grpc.ClientStream
}

type Source_SyncServer

type Source_SyncServer interface {
	Send(*Sync_Response) error
	grpc.ServerStream
}

type Sync

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

func (*Sync) Descriptor deprecated

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

Deprecated: Use Sync.ProtoReflect.Descriptor instead.

func (*Sync) ProtoMessage

func (*Sync) ProtoMessage()

func (*Sync) ProtoReflect

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

func (*Sync) Reset

func (x *Sync) Reset()

func (*Sync) String

func (x *Sync) String() string

type Sync_Request

type Sync_Request struct {
	SyncTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync_Request) Descriptor deprecated

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

Deprecated: Use Sync_Request.ProtoReflect.Descriptor instead.

func (*Sync_Request) GetSyncTime added in v1.0.8

func (x *Sync_Request) GetSyncTime() *timestamppb.Timestamp

func (*Sync_Request) ProtoMessage

func (*Sync_Request) ProtoMessage()

func (*Sync_Request) ProtoReflect

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

func (*Sync_Request) Reset

func (x *Sync_Request) Reset()

func (*Sync_Request) String

func (x *Sync_Request) String() string

type Sync_Response

type Sync_Response struct {

	// marshalled *arrow.Records
	Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync_Response) Descriptor deprecated

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

Deprecated: Use Sync_Response.ProtoReflect.Descriptor instead.

func (*Sync_Response) GetResource

func (x *Sync_Response) GetResource() []byte

func (*Sync_Response) ProtoMessage

func (*Sync_Response) ProtoMessage()

func (*Sync_Response) ProtoReflect

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

func (*Sync_Response) Reset

func (x *Sync_Response) Reset()

func (*Sync_Response) String

func (x *Sync_Response) String() string

type UnimplementedSourceServer

type UnimplementedSourceServer struct {
}

UnimplementedSourceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServer) GenDocs

func (UnimplementedSourceServer) GetMetrics

func (UnimplementedSourceServer) GetName

func (UnimplementedSourceServer) GetTables

func (UnimplementedSourceServer) GetVersion

func (UnimplementedSourceServer) Init

func (UnimplementedSourceServer) Sync

type UnsafeSourceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL