Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

remote

package

Go to main page

Versions in this module

v0

v0.4.2

Jun 28, 2023

v0.4.1

Feb 9, 2023

v0.4.0

Nov 9, 2022

v0.3.2

Sep 5, 2022

v0.3.1

Aug 30, 2022

v0.3.0

Aug 18, 2022

v0.2.0

Jun 9, 2022

Changes in this version

+ var Plugin_ServiceDesc = grpc.ServiceDesc

+ var VCluster_ServiceDesc = grpc.ServiceDesc

+ func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)

+ func RegisterVClusterServer(s grpc.ServiceRegistrar, srv VClusterServer)

+ type ClientHook struct

+ ApiVersion string

+ Kind string

+ Types []string

+ func (*ClientHook) Descriptor() ([]byte, []int)

+ func (*ClientHook) ProtoMessage()

+ func (x *ClientHook) GetApiVersion() string

+ func (x *ClientHook) GetKind() string

+ func (x *ClientHook) GetTypes() []string

+ func (x *ClientHook) ProtoReflect() protoreflect.Message

+ func (x *ClientHook) Reset()

+ func (x *ClientHook) String() string

type LeaderInfo

+ RunID string

+ func (x *LeaderInfo) GetRunID() string

+ type MutateRequest struct

+ ApiVersion string

+ Kind string

+ Object string

+ Type string

+ func (*MutateRequest) Descriptor() ([]byte, []int)

+ func (*MutateRequest) ProtoMessage()

+ func (x *MutateRequest) GetApiVersion() string

+ func (x *MutateRequest) GetKind() string

+ func (x *MutateRequest) GetObject() string

+ func (x *MutateRequest) GetType() string

+ func (x *MutateRequest) ProtoReflect() protoreflect.Message

+ func (x *MutateRequest) Reset()

+ func (x *MutateRequest) String() string

+ type MutateResult struct

+ Mutated bool

+ Object string

+ func (*MutateResult) Descriptor() ([]byte, []int)

+ func (*MutateResult) ProtoMessage()

+ func (x *MutateResult) GetMutated() bool

+ func (x *MutateResult) GetObject() string

+ func (x *MutateResult) ProtoReflect() protoreflect.Message

+ func (x *MutateResult) Reset()

+ func (x *MutateResult) String() string

+ type PluginClient interface

+ Mutate func(ctx context.Context, in *MutateRequest, opts ...grpc.CallOption) (*MutateResult, error)

+ func NewPluginClient(cc grpc.ClientConnInterface) PluginClient

+ type PluginServer interface

+ Mutate func(context.Context, *MutateRequest) (*MutateResult, error)

+ type RegisterPluginRequest struct

+ Address string

+ ClientHooks []*ClientHook

+ Name string

+ Version string

+ func (*RegisterPluginRequest) Descriptor() ([]byte, []int)

+ func (*RegisterPluginRequest) ProtoMessage()

+ func (x *RegisterPluginRequest) GetAddress() string

+ func (x *RegisterPluginRequest) GetClientHooks() []*ClientHook

+ func (x *RegisterPluginRequest) GetName() string

+ func (x *RegisterPluginRequest) GetVersion() string

+ func (x *RegisterPluginRequest) ProtoReflect() protoreflect.Message

+ func (x *RegisterPluginRequest) Reset()

+ func (x *RegisterPluginRequest) String() string

+ type RegisterPluginResult struct

+ func (*RegisterPluginResult) Descriptor() ([]byte, []int)

+ func (*RegisterPluginResult) ProtoMessage()

+ func (x *RegisterPluginResult) ProtoReflect() protoreflect.Message

+ func (x *RegisterPluginResult) Reset()

+ func (x *RegisterPluginResult) String() string

+ type UnimplementedPluginServer struct

+ func (UnimplementedPluginServer) Mutate(context.Context, *MutateRequest) (*MutateResult, error)

+ type UnimplementedVClusterServer struct

+ func (UnimplementedVClusterServer) GetContext(context.Context, *Empty) (*Context, error)

+ func (UnimplementedVClusterServer) IsLeader(context.Context, *Empty) (*LeaderInfo, error)

+ func (UnimplementedVClusterServer) Register(context.Context, *PluginInfo) (*Context, error)

+ func (UnimplementedVClusterServer) RegisterPlugin(context.Context, *RegisterPluginRequest) (*RegisterPluginResult, error)

+ type UnsafePluginServer interface

+ type UnsafeVClusterServer interface

+ type VClusterClient interface

+ GetContext func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Context, error)

+ IsLeader func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*LeaderInfo, error)

+ Register func(ctx context.Context, in *PluginInfo, opts ...grpc.CallOption) (*Context, error)

+ RegisterPlugin func(ctx context.Context, in *RegisterPluginRequest, opts ...grpc.CallOption) (*RegisterPluginResult, error)

+ func NewVClusterClient(cc grpc.ClientConnInterface) VClusterClient

+ type VClusterServer interface

+ GetContext func(context.Context, *Empty) (*Context, error)

+ IsLeader func(context.Context, *Empty) (*LeaderInfo, error)

+ Register func(context.Context, *PluginInfo) (*Context, error)

+ RegisterPlugin func(context.Context, *RegisterPluginRequest) (*RegisterPluginResult, error)

v0.2.0-beta.1

May 30, 2022

v0.2.0-beta.0

May 27, 2022

v0.1.1

Mar 11, 2022

v0.1.0

Jan 24, 2022

Changes in this version

+ var File_plugin_proto protoreflect.FileDescriptor

+ var PluginInitializer_ServiceDesc = grpc.ServiceDesc

+ func RegisterPluginInitializerServer(s grpc.ServiceRegistrar, srv PluginInitializerServer)

+ type Context struct

+ CurrentNamespace string

+ Options string

+ PhysicalClusterConfig string

+ SyncerConfig string

+ TargetNamespace string

+ VirtualClusterConfig string

+ func (*Context) Descriptor() ([]byte, []int)

+ func (*Context) ProtoMessage()

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

+ func (x *Context) Reset()

+ func (x *Context) String() string

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (x *Empty) ProtoReflect() protoreflect.Message

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type LeaderInfo struct

+ Leader bool

+ func (*LeaderInfo) Descriptor() ([]byte, []int)

+ func (*LeaderInfo) ProtoMessage()

+ func (x *LeaderInfo) GetLeader() bool

+ func (x *LeaderInfo) ProtoReflect() protoreflect.Message

+ func (x *LeaderInfo) Reset()

+ func (x *LeaderInfo) String() string

+ type PluginInfo struct

+ Name string

+ func (*PluginInfo) Descriptor() ([]byte, []int)

+ func (*PluginInfo) ProtoMessage()

+ func (x *PluginInfo) GetName() string

+ func (x *PluginInfo) ProtoReflect() protoreflect.Message

+ func (x *PluginInfo) Reset()

+ func (x *PluginInfo) String() string

+ type PluginInitializerClient interface

+ IsLeader func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*LeaderInfo, error)

+ Register func(ctx context.Context, in *PluginInfo, opts ...grpc.CallOption) (*Context, error)

+ func NewPluginInitializerClient(cc grpc.ClientConnInterface) PluginInitializerClient

+ type PluginInitializerServer interface

+ IsLeader func(context.Context, *Empty) (*LeaderInfo, error)

+ Register func(context.Context, *PluginInfo) (*Context, error)

+ type UnimplementedPluginInitializerServer struct

+ func (UnimplementedPluginInitializerServer) IsLeader(context.Context, *Empty) (*LeaderInfo, error)

+ func (UnimplementedPluginInitializerServer) Register(context.Context, *PluginInfo) (*Context, error)

+ type UnsafePluginInitializerServer interface