lock

Documentation

Overview

Code generated by atomix-go-framework. DO NOT EDIT.

Code generated by atomix-go-framework. DO NOT EDIT.

Index

• func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) lock.LockServiceServer
• type ProxyRegistry
  • func NewProxyRegistry() *ProxyRegistry
  • func (r *ProxyRegistry) AddProxy(id primitiveapi.PrimitiveId, server lock.LockServiceServer) error
  • func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (lock.LockServiceServer, error)
  • func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error
• type ProxyServer
  • func (s *ProxyServer) GetLock(ctx context.Context, request *lock.GetLockRequest) (*lock.GetLockResponse, error)
  • func (s *ProxyServer) Lock(ctx context.Context, request *lock.LockRequest) (*lock.LockResponse, error)
  • func (s *ProxyServer) Unlock(ctx context.Context, request *lock.UnlockRequest) (*lock.UnlockResponse, error)

Functions

func NewProxyServer

func NewProxyServer(registry *ProxyRegistry, env env.DriverEnv) lock.LockServiceServer

NewProxyServer creates a new ProxyServer

Types

type ProxyRegistry

type ProxyRegistry struct {
	// contains filtered or unexported fields
}

func NewProxyRegistry

func NewProxyRegistry() *ProxyRegistry

NewProxyRegistry creates a new ProxyRegistry

func (*ProxyRegistry) AddProxy

func (r *ProxyRegistry) AddProxy(id primitiveapi.PrimitiveId, server lock.LockServiceServer) error

func (*ProxyRegistry) GetProxy

func (r *ProxyRegistry) GetProxy(id primitiveapi.PrimitiveId) (lock.LockServiceServer, error)

func (*ProxyRegistry) RemoveProxy

func (r *ProxyRegistry) RemoveProxy(id primitiveapi.PrimitiveId) error

type ProxyServer

type ProxyServer struct {
	// contains filtered or unexported fields
}

func (*ProxyServer) GetLock

func (s *ProxyServer) GetLock(ctx context.Context, request *lock.GetLockRequest) (*lock.GetLockResponse, error)

func (*ProxyServer) Lock

func (s *ProxyServer) Lock(ctx context.Context, request *lock.LockRequest) (*lock.LockResponse, error)

func (*ProxyServer) Unlock

func (s *ProxyServer) Unlock(ctx context.Context, request *lock.UnlockRequest) (*lock.UnlockResponse, error)