ms

Documentation

Index

• func Init(opts Options) error
• func Install(pluginImplName string, engineFunc dataSourceEngine)
• type DataSource
  • func MicroService() DataSource
• type ImplName
• type Options

Functions

func Init

func Init(opts Options) error

construct storage plugin instance invoked by sc main process

func Install

func Install(pluginImplName string, engineFunc dataSourceEngine)

load plugins configuration into plugins

Types

type DataSource

type DataSource interface {
	RegisterService(ctx context.Context, request *pb.CreateServiceRequest) (*pb.CreateServiceResponse, error)
	GetServices(ctx context.Context, request *pb.GetServicesRequest) (*pb.GetServicesResponse, error)
	GetService(ctx context.Context, request *pb.GetServiceRequest) (*pb.GetServiceResponse, error)
	ExistService(ctx context.Context, request *pb.GetExistenceRequest) (*pb.GetExistenceResponse, error)
	UpdateService(ctx context.Context, request *pb.UpdateServicePropsRequest) (*pb.UpdateServicePropsResponse, error)
	UnregisterService(ctx context.Context, request *pb.DeleteServiceRequest) (*pb.DeleteServiceResponse, error)
	GetDeleteServiceFunc(ctx context.Context, serviceID string, force bool,
		serviceRespChan chan<- *pb.DelServicesRspInfo) func(context.Context)

	RegisterInstance(ctx context.Context, in *pb.RegisterInstanceRequest) (*pb.RegisterInstanceResponse, error)
	SearchInstance()
	UpdateInstance()
	UnRegisterInstance()

	ModifySchemas(ctx context.Context, request *pb.ModifySchemasRequest) (*pb.ModifySchemasResponse, error)
	ModifySchema(ctx context.Context, request *pb.ModifySchemaRequest) (*pb.ModifySchemaResponse, error)
	ExistSchema(ctx context.Context, request *pb.GetExistenceRequest) (*pb.GetExistenceResponse, error)
	GetSchema()
	DeleteSchema()

	AddTag()
	GetTag()
	UpdateTag()
	DeleteTag()

	AddRule()
	GetRule()
	UpdateRule()
	DeleteRule()
}

Attention: request validation must be finished before the following interface being invoked!!!

func MicroService

func MicroService() DataSource

usage: ms.MicroService().create()

type ImplName

type ImplName string

type Options

type Options struct {
	Endpoint       string
	PluginImplName ImplName
	SchemaEditable bool
	TTL            int64
}

Options contains configuration for plugins