rpc

Documentation

Index

• func RegisterLockReleaseProcedure() error
• func ReleaseLock(hostIP, clientIP string) error
• type LockReleaseController
  • func NewLockReleaseController(client kubernetes.Interface, config *LockReleaseControllerConfig) (*LockReleaseController, error)
  • func (c *LockReleaseController) Run(ctx context.Context)
• type LockReleaseControllerConfig

Functions

func RegisterLockReleaseProcedure

func RegisterLockReleaseProcedure() error

Register rpc procedure for lock release. This function will be called during lock release controller initialization.

func ReleaseLock

func ReleaseLock(hostIP, clientIP string) error

ReleaseLock calls the Filestore server to remove all advisory locks for a given GKE node IP. hostIP is the internal IP address of the Filestore instance. clientIP is the internal IP address of the GKE node.

Types

type LockReleaseController

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

func NewLockReleaseController

func NewLockReleaseController(client kubernetes.Interface, config *LockReleaseControllerConfig) (*LockReleaseController, error)

func (*LockReleaseController) Run

func (c *LockReleaseController) Run(ctx context.Context)

type LockReleaseControllerConfig

type LockReleaseControllerConfig struct {
	// Parameters of leaderelection.LeaderElectionConfig.
	LeaseDuration, RenewDeadline, RetryPeriod time.Duration
	// Reconcile loop frequency.
	SyncPeriod time.Duration
}