source

package
v1.12.0 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2023 License: MPL-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	Source_GetProtocolVersion_FullMethodName = "/proto.Source/GetProtocolVersion"
	Source_GetName_FullMethodName            = "/proto.Source/GetName"
	Source_GetVersion_FullMethodName         = "/proto.Source/GetVersion"
	Source_GetTables_FullMethodName          = "/proto.Source/GetTables"
	Source_GetTablesForSpec_FullMethodName   = "/proto.Source/GetTablesForSpec"
	Source_GetSyncSummary_FullMethodName     = "/proto.Source/GetSyncSummary"
	Source_Sync_FullMethodName               = "/proto.Source/Sync"
	Source_Sync2_FullMethodName              = "/proto.Source/Sync2"
	Source_GetMetrics_FullMethodName         = "/proto.Source/GetMetrics"
)

Variables

View Source 
var File_plugin_pb_source_v0_source_proto protoreflect.FileDescriptor
View Source 
var Source_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Source",
	HandlerType: (*SourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetProtocolVersion",
			Handler:    _Source_GetProtocolVersion_Handler,
		},
		{
			MethodName: "GetName",
			Handler:    _Source_GetName_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Source_GetVersion_Handler,
		},
		{
			MethodName: "GetTables",
			Handler:    _Source_GetTables_Handler,
		},
		{
			MethodName: "GetTablesForSpec",
			Handler:    _Source_GetTablesForSpec_Handler,
		},
		{
			MethodName: "GetSyncSummary",
			Handler:    _Source_GetSyncSummary_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _Source_GetMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sync",
			Handler:       _Source_Sync_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Sync2",
			Handler:       _Source_Sync2_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "plugin-pb/source/v0/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 RegisterSourceServer 

func RegisterSourceServer(s grpc.ServiceRegistrar, srv SourceServer)

Types

type GetSourceMetrics 

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

func (*GetSourceMetrics) Descriptor deprecated 

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

Deprecated: Use GetSourceMetrics.ProtoReflect.Descriptor instead.

func (*GetSourceMetrics) ProtoMessage 

func (*GetSourceMetrics) ProtoMessage()

func (*GetSourceMetrics) ProtoReflect 

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

func (*GetSourceMetrics) Reset 

func (x *GetSourceMetrics) Reset()

func (*GetSourceMetrics) String 

func (x *GetSourceMetrics) String() string

type GetSourceMetrics_Request 

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

func (*GetSourceMetrics_Request) Descriptor deprecated 

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

Deprecated: Use GetSourceMetrics_Request.ProtoReflect.Descriptor instead.

func (*GetSourceMetrics_Request) ProtoMessage 

func (*GetSourceMetrics_Request) ProtoMessage()

func (*GetSourceMetrics_Request) ProtoReflect 

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

func (*GetSourceMetrics_Request) Reset 

func (x *GetSourceMetrics_Request) Reset()

func (*GetSourceMetrics_Request) String 

func (x *GetSourceMetrics_Request) String() string

type GetSourceMetrics_Response 

type GetSourceMetrics_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 (*GetSourceMetrics_Response) Descriptor deprecated 

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

Deprecated: Use GetSourceMetrics_Response.ProtoReflect.Descriptor instead.

func (*GetSourceMetrics_Response) GetMetrics 

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

func (*GetSourceMetrics_Response) ProtoMessage 

func (*GetSourceMetrics_Response) ProtoMessage()

func (*GetSourceMetrics_Response) ProtoReflect 

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

func (*GetSourceMetrics_Response) Reset 

func (x *GetSourceMetrics_Response) Reset()

func (*GetSourceMetrics_Response) String 

func (x *GetSourceMetrics_Response) String() string

type GetSyncSummary 

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

func (*GetSyncSummary) Descriptor deprecated 

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

Deprecated: Use GetSyncSummary.ProtoReflect.Descriptor instead.

func (*GetSyncSummary) ProtoMessage 

func (*GetSyncSummary) ProtoMessage()

func (*GetSyncSummary) ProtoReflect 

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

func (*GetSyncSummary) Reset 

func (x *GetSyncSummary) Reset()

func (*GetSyncSummary) String 

func (x *GetSyncSummary) String() string

type GetSyncSummary_Request 

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

func (*GetSyncSummary_Request) Descriptor deprecated 

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

Deprecated: Use GetSyncSummary_Request.ProtoReflect.Descriptor instead.

func (*GetSyncSummary_Request) ProtoMessage 

func (*GetSyncSummary_Request) ProtoMessage()

func (*GetSyncSummary_Request) ProtoReflect 

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

func (*GetSyncSummary_Request) Reset 

func (x *GetSyncSummary_Request) Reset()

func (*GetSyncSummary_Request) String 

func (x *GetSyncSummary_Request) String() string

type GetSyncSummary_Response 

type GetSyncSummary_Response struct {

	// marshalled *schema.SyncSummary
	Summary []byte `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSyncSummary_Response) Descriptor deprecated 

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

Deprecated: Use GetSyncSummary_Response.ProtoReflect.Descriptor instead.

func (*GetSyncSummary_Response) GetSummary 

func (x *GetSyncSummary_Response) GetSummary() []byte

func (*GetSyncSummary_Response) ProtoMessage 

func (*GetSyncSummary_Response) ProtoMessage()

func (*GetSyncSummary_Response) ProtoReflect 

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

func (*GetSyncSummary_Response) Reset 

func (x *GetSyncSummary_Response) Reset()

func (*GetSyncSummary_Response) String 

func (x *GetSyncSummary_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 GetTablesForSpec 

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

func (*GetTablesForSpec) Descriptor deprecated 

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

Deprecated: Use GetTablesForSpec.ProtoReflect.Descriptor instead.

func (*GetTablesForSpec) ProtoMessage 

func (*GetTablesForSpec) ProtoMessage()

func (*GetTablesForSpec) ProtoReflect 

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

func (*GetTablesForSpec) Reset 

func (x *GetTablesForSpec) Reset()

func (*GetTablesForSpec) String 

func (x *GetTablesForSpec) String() string

type GetTablesForSpec_Request 

type GetTablesForSpec_Request struct {

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

func (*GetTablesForSpec_Request) Descriptor deprecated 

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

Deprecated: Use GetTablesForSpec_Request.ProtoReflect.Descriptor instead.

func (*GetTablesForSpec_Request) GetSpec 

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

func (*GetTablesForSpec_Request) ProtoMessage 

func (*GetTablesForSpec_Request) ProtoMessage()

func (*GetTablesForSpec_Request) ProtoReflect 

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

func (*GetTablesForSpec_Request) Reset 

func (x *GetTablesForSpec_Request) Reset()

func (*GetTablesForSpec_Request) String 

func (x *GetTablesForSpec_Request) String() string

type GetTablesForSpec_Response 

type GetTablesForSpec_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 []*schema.Table
	Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTablesForSpec_Response) Descriptor deprecated 

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

Deprecated: Use GetTablesForSpec_Response.ProtoReflect.Descriptor instead.

func (*GetTablesForSpec_Response) GetName 

func (x *GetTablesForSpec_Response) GetName() string

func (*GetTablesForSpec_Response) GetTables 

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

func (*GetTablesForSpec_Response) GetVersion 

func (x *GetTablesForSpec_Response) GetVersion() string

func (*GetTablesForSpec_Response) ProtoMessage 

func (*GetTablesForSpec_Response) ProtoMessage()

func (*GetTablesForSpec_Response) ProtoReflect 

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

func (*GetTablesForSpec_Response) Reset 

func (x *GetTablesForSpec_Response) Reset()

func (*GetTablesForSpec_Response) String 

func (x *GetTablesForSpec_Response) 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 []*schema.Table
	Tables []byte `protobuf:"bytes,3,opt,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 SourceClient 

type SourceClient interface {
	// Get the current protocol version of the plugin. This helps
	// get the right message about upgrade/downgrade of cli and/or plugin.
	// Also, on the cli side it can try to upgrade/downgrade the protocol if cli supports it.
	// Depcrecated: use GetSupportedProtocolVersions instead
	GetProtocolVersion(ctx context.Context, in *v0.GetProtocolVersion_Request, opts ...grpc.CallOption) (*v0.GetProtocolVersion_Response, error)
	// Get the name of the plugin
	GetName(ctx context.Context, in *v0.GetName_Request, opts ...grpc.CallOption) (*v0.GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(ctx context.Context, in *v0.GetVersion_Request, opts ...grpc.CallOption) (*v0.GetVersion_Response, error)
	// Get all tables the source plugin supports
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// Get all tables the source plugin supports, optionally filtered by a given spec.
	// Introduced in version 2 of the protocol.
	GetTablesForSpec(ctx context.Context, in *GetTablesForSpec_Request, opts ...grpc.CallOption) (*GetTablesForSpec_Response, error)
	// GetSyncSummary returns the latest sync summary of the source plugin. we don't want to send the summary on
	// every sync request.
	GetSyncSummary(ctx context.Context, in *GetSyncSummary_Request, opts ...grpc.CallOption) (*GetSyncSummary_Response, error)
	// Fetch resources
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error)
	// Sync2 is a new sync API that supports CQ Types. It is not backward compatible with Sync.
	Sync2(ctx context.Context, in *Sync2_Request, opts ...grpc.CallOption) (Source_Sync2Client, error)
	// Get metrics for the source plugin
	GetMetrics(ctx context.Context, in *GetSourceMetrics_Request, opts ...grpc.CallOption) (*GetSourceMetrics_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 current protocol version of the plugin. This helps
	// get the right message about upgrade/downgrade of cli and/or plugin.
	// Also, on the cli side it can try to upgrade/downgrade the protocol if cli supports it.
	// Depcrecated: use GetSupportedProtocolVersions instead
	GetProtocolVersion(context.Context, *v0.GetProtocolVersion_Request) (*v0.GetProtocolVersion_Response, error)
	// Get the name of the plugin
	GetName(context.Context, *v0.GetName_Request) (*v0.GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(context.Context, *v0.GetVersion_Request) (*v0.GetVersion_Response, error)
	// Get all tables the source plugin supports
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// Get all tables the source plugin supports, optionally filtered by a given spec.
	// Introduced in version 2 of the protocol.
	GetTablesForSpec(context.Context, *GetTablesForSpec_Request) (*GetTablesForSpec_Response, error)
	// GetSyncSummary returns the latest sync summary of the source plugin. we don't want to send the summary on
	// every sync request.
	GetSyncSummary(context.Context, *GetSyncSummary_Request) (*GetSyncSummary_Response, error)
	// Fetch resources
	Sync(*Sync_Request, Source_SyncServer) error
	// Sync2 is a new sync API that supports CQ Types. It is not backward compatible with Sync.
	Sync2(*Sync2_Request, Source_Sync2Server) error
	// Get metrics for the source plugin
	GetMetrics(context.Context, *GetSourceMetrics_Request) (*GetSourceMetrics_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_Sync2Client 

type Source_Sync2Client interface {
	Recv() (*Sync2_Response, error)
	grpc.ClientStream
}

type Source_Sync2Server 

type Source_Sync2Server interface {
	Send(*Sync2_Response) error
	grpc.ServerStream
}

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 Sync2 

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

func (*Sync2) Descriptor deprecated 

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

Deprecated: Use Sync2.ProtoReflect.Descriptor instead.

func (*Sync2) ProtoMessage 

func (*Sync2) ProtoMessage()

func (*Sync2) ProtoReflect 

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

func (*Sync2) Reset 

func (x *Sync2) Reset()

func (*Sync2) String 

func (x *Sync2) String() string

type Sync2_Request 

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

func (*Sync2_Request) Descriptor deprecated 

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

Deprecated: Use Sync2_Request.ProtoReflect.Descriptor instead.

func (*Sync2_Request) GetSpec 

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

func (*Sync2_Request) ProtoMessage 

func (*Sync2_Request) ProtoMessage()

func (*Sync2_Request) ProtoReflect 

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

func (*Sync2_Request) Reset 

func (x *Sync2_Request) Reset()

func (*Sync2_Request) String 

func (x *Sync2_Request) String() string

type Sync2_Response 

type Sync2_Response struct {

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

func (*Sync2_Response) Descriptor deprecated 

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

Deprecated: Use Sync2_Response.ProtoReflect.Descriptor instead.

func (*Sync2_Response) GetResource 

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

func (*Sync2_Response) ProtoMessage 

func (*Sync2_Response) ProtoMessage()

func (*Sync2_Response) ProtoReflect 

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

func (*Sync2_Response) Reset 

func (x *Sync2_Response) Reset()

func (*Sync2_Response) String 

func (x *Sync2_Response) String() string

type Sync_Request 

type Sync_Request struct {
	Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// sync timestamp
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,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) GetSpec 

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

func (*Sync_Request) GetTimestamp 

func (x *Sync_Request) GetTimestamp() *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 *schema.Resources
	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) GetMetrics 

func (UnimplementedSourceServer) GetMetrics(context.Context, *GetSourceMetrics_Request) (*GetSourceMetrics_Response, error)

func (UnimplementedSourceServer) GetName 

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

func (UnimplementedSourceServer) GetProtocolVersion 

func (UnimplementedSourceServer) GetProtocolVersion(context.Context, *v0.GetProtocolVersion_Request) (*v0.GetProtocolVersion_Response, error)

func (UnimplementedSourceServer) GetSyncSummary 

func (UnimplementedSourceServer) GetSyncSummary(context.Context, *GetSyncSummary_Request) (*GetSyncSummary_Response, error)

func (UnimplementedSourceServer) GetTables 

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

func (UnimplementedSourceServer) GetTablesForSpec 

func (UnimplementedSourceServer) GetTablesForSpec(context.Context, *GetTablesForSpec_Request) (*GetTablesForSpec_Response, error)

func (UnimplementedSourceServer) GetVersion 

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

func (UnimplementedSourceServer) Sync 

func (UnimplementedSourceServer) Sync(*Sync_Request, Source_SyncServer) error

func (UnimplementedSourceServer) Sync2 

func (UnimplementedSourceServer) Sync2(*Sync2_Request, Source_Sync2Server) 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.