Documentation
¶
Index ¶
- Variables
- func RegisterPluginInitializerServer(s grpc.ServiceRegistrar, srv PluginInitializerServer)
- type Context
- func (*Context) Descriptor() ([]byte, []int)deprecated
- func (x *Context) GetCurrentNamespace() string
- func (x *Context) GetOptions() string
- func (x *Context) GetPhysicalClusterConfig() string
- func (x *Context) GetSyncerConfig() string
- func (x *Context) GetTargetNamespace() string
- func (x *Context) GetVirtualClusterConfig() string
- func (*Context) ProtoMessage()
- func (x *Context) ProtoReflect() protoreflect.Message
- func (x *Context) Reset()
- func (x *Context) String() string
- type Empty
- type LeaderInfo
- type PluginInfo
- type PluginInitializerClient
- type PluginInitializerServer
- type UnimplementedPluginInitializerServer
- type UnsafePluginInitializerServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_plugin_proto protoreflect.FileDescriptor
View Source
var PluginInitializer_ServiceDesc = grpc.ServiceDesc{
ServiceName: "remote.PluginInitializer",
HandlerType: (*PluginInitializerServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Register",
Handler: _PluginInitializer_Register_Handler,
},
{
MethodName: "IsLeader",
Handler: _PluginInitializer_IsLeader_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "plugin.proto",
}
PluginInitializer_ServiceDesc is the grpc.ServiceDesc for PluginInitializer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPluginInitializerServer ¶
func RegisterPluginInitializerServer(s grpc.ServiceRegistrar, srv PluginInitializerServer)
Types ¶
type Context ¶
type Context struct {
VirtualClusterConfig string `protobuf:"bytes,1,opt,name=virtualClusterConfig,proto3" json:"virtualClusterConfig,omitempty"`
PhysicalClusterConfig string `protobuf:"bytes,2,opt,name=physicalClusterConfig,proto3" json:"physicalClusterConfig,omitempty"`
SyncerConfig string `protobuf:"bytes,3,opt,name=syncerConfig,proto3" json:"syncerConfig,omitempty"`
TargetNamespace string `protobuf:"bytes,4,opt,name=targetNamespace,proto3" json:"targetNamespace,omitempty"`
CurrentNamespace string `protobuf:"bytes,5,opt,name=currentNamespace,proto3" json:"currentNamespace,omitempty"`
Options string `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*Context) Descriptor
deprecated
func (*Context) Descriptor() ([]byte, []int)
Deprecated: Use Context.ProtoReflect.Descriptor instead.
func (*Context) GetCurrentNamespace ¶
func (x *Context) GetCurrentNamespace() string
func (*Context) GetOptions ¶
func (x *Context) GetOptions() string
func (*Context) GetPhysicalClusterConfig ¶
func (x *Context) GetPhysicalClusterConfig() string
func (*Context) GetSyncerConfig ¶
func (x *Context) GetSyncerConfig() string
func (*Context) GetTargetNamespace ¶
func (x *Context) GetTargetNamespace() string
func (*Context) GetVirtualClusterConfig ¶
func (x *Context) GetVirtualClusterConfig() string
func (*Context) ProtoMessage ¶
func (*Context) ProtoMessage()
func (*Context) ProtoReflect ¶
func (x *Context) ProtoReflect() protoreflect.Message
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) Descriptor() ([]byte, []int)
Deprecated: Use Empty.ProtoReflect.Descriptor instead.
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type LeaderInfo ¶
type LeaderInfo struct {
Leader bool `protobuf:"varint,1,opt,name=leader,proto3" json:"leader,omitempty"`
// contains filtered or unexported fields
}
func (*LeaderInfo) Descriptor
deprecated
func (*LeaderInfo) Descriptor() ([]byte, []int)
Deprecated: Use LeaderInfo.ProtoReflect.Descriptor instead.
func (*LeaderInfo) ProtoMessage ¶
func (*LeaderInfo) ProtoMessage()
func (*LeaderInfo) ProtoReflect ¶
func (x *LeaderInfo) ProtoReflect() protoreflect.Message
type PluginInfo ¶
type PluginInfo struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*PluginInfo) Descriptor
deprecated
func (*PluginInfo) Descriptor() ([]byte, []int)
Deprecated: Use PluginInfo.ProtoReflect.Descriptor instead.
func (*PluginInfo) ProtoMessage ¶
func (*PluginInfo) ProtoMessage()
func (*PluginInfo) ProtoReflect ¶
func (x *PluginInfo) ProtoReflect() protoreflect.Message
type PluginInitializerClient ¶
type PluginInitializerClient interface {
Register(ctx context.Context, in *PluginInfo, opts ...grpc.CallOption) (*Context, error)
IsLeader(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*LeaderInfo, error)
}
PluginInitializerClient is the client API for PluginInitializer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPluginInitializerClient ¶
func NewPluginInitializerClient(cc grpc.ClientConnInterface) PluginInitializerClient
type PluginInitializerServer ¶
type PluginInitializerServer interface {
Register(context.Context, *PluginInfo) (*Context, error)
IsLeader(context.Context, *Empty) (*LeaderInfo, error)
// contains filtered or unexported methods
}
PluginInitializerServer is the server API for PluginInitializer service. All implementations must embed UnimplementedPluginInitializerServer for forward compatibility
type UnimplementedPluginInitializerServer ¶
type UnimplementedPluginInitializerServer struct {
}
UnimplementedPluginInitializerServer must be embedded to have forward compatible implementations.
type UnsafePluginInitializerServer ¶
type UnsafePluginInitializerServer interface {
// contains filtered or unexported methods
}
UnsafePluginInitializerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginInitializerServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.