source

package
v1.25.3 Latest Latest
Warning

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

 Go to latest Published: Dec 2, 2024 License: MPL-2.0 Imports: 12 Imported by: 3

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) Descriptor() protoreflect.EnumDescriptor

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 (x GenDocs_FORMAT) Number() protoreflect.EnumNumber

func (GenDocs_FORMAT) String 

func (x GenDocs_FORMAT) String() string

func (GenDocs_FORMAT) Type 

func (GenDocs_FORMAT) Type() protoreflect.EnumType

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 (x *GetDynamicTables_Response) ProtoReflect() protoreflect.Message

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) (grpc.ServerStreamingClient[Sync_Response], 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, grpc.ServerStreamingServer[Sync_Response]) 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 = grpc.ServerStreamingClient[Sync_Response]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Source_SyncServer 

type Source_SyncServer = grpc.ServerStreamingServer[Sync_Response]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSourceServer) GenDocs 

func (UnimplementedSourceServer) GenDocs(context.Context, *GenDocs_Request) (*GenDocs_Response, error)

func (UnimplementedSourceServer) GetDynamicTables 

func (UnimplementedSourceServer) GetDynamicTables(context.Context, *GetDynamicTables_Request) (*GetDynamicTables_Response, error)

func (UnimplementedSourceServer) GetMetrics 

func (UnimplementedSourceServer) GetMetrics(context.Context, *GetMetrics_Request) (*GetMetrics_Response, error)

func (UnimplementedSourceServer) GetName 

func (UnimplementedSourceServer) GetName(context.Context, *GetName_Request) (*GetName_Response, error)

func (UnimplementedSourceServer) GetTables 

func (UnimplementedSourceServer) GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)

func (UnimplementedSourceServer) GetVersion 

func (UnimplementedSourceServer) GetVersion(context.Context, *GetVersion_Request) (*GetVersion_Response, error)

func (UnimplementedSourceServer) Init 

func (UnimplementedSourceServer) Init(context.Context, *Init_Request) (*Init_Response, error)

func (UnimplementedSourceServer) Sync 

func (UnimplementedSourceServer) Sync(*Sync_Request, grpc.ServerStreamingServer[Sync_Response]) error

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.

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.