gomesh

type Agent interface {
	Start(config config.Config) error
	Config(name string) (config.Config, error)
	Listen() (net.Listener, error)
	Connect(name string, options ...grpc.DialOption) (*grpc.ClientConn, error)
}

type F func(config config.Config) (Service, error)

type GrpcService interface {
	Service
	GrpcHandle(server *grpc.Server) error
}

type Register interface {
	LocalService(name string, F F)
	RemoteService(name string, F RemoteF)
	Start(agent Agent, tccServer TccServer) error
}

type RemoteF func(conn *grpc.ClientConn) (Service, error)

type RunnableService interface {
	Start() error
}

type Service interface {
}

type TccResource struct {
	GrpcRequireFullMethod string
	Commit                func(txid string) error
	Cancel                func(txid string) error
}

type TccServer interface {
	Start(config config.Config) error
	Register(tccResource TccResource) error
	NewTx(parentTxid string) (string, error)
	Commit(txid string) error
	Cancel(txid string) error
	BeforeRequire(ctx context.Context, GrpcRequireFullMethod string) error
	AfterRequire(ctx context.Context, GrpcRequireFullMethod string) error
}

type TccService interface {
	GrpcService
	TccHandle(server TccServer) error
}