plugin

Jan 16, 2026

Changes in this version

+ type GRPCClient struct

+ func NewGRPCClient(conn *grpc.ClientConn) *GRPCClient

+ func (c *GRPCClient) Init(config map[string]string) error

+ func (c *GRPCClient) Push(taskID string, status planning.TaskStatus) error

+ func (c *GRPCClient) Sync(plan *planning.Plan, state *planning.ExecutionState) (*domainPlugin.SyncResult, error)

+ type GRPCServer struct

+ Impl domainPlugin.Syncer

+ func (s *GRPCServer) Init(ctx context.Context, req *pb.InitRequest) (*pb.InitResponse, error)

+ func (s *GRPCServer) Push(ctx context.Context, req *pb.PushRequest) (*pb.PushResponse, error)

+ func (s *GRPCServer) Subscribe(req *pb.SubscribeRequest, stream pb.Syncer_SubscribeServer) error

+ func (s *GRPCServer) Sync(ctx context.Context, req *pb.SyncRequest) (*pb.SyncResponse, error)

Jan 13, 2026

Changes in this version

+ var HandshakeConfig = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ type Loader struct

+ func NewLoader() *Loader

+ func (l *Loader) Cleanup()

+ func (l *Loader) Load(path string) (domainPlugin.Syncer, error)