...

Source file src/edge-infra.dev/pkg/sds/lib/etcd/client/errors.go

Documentation: edge-infra.dev/pkg/sds/lib/etcd/client

     1  package client
     2  
     3  import (
     4  	"errors"
     5  
     6  	"go.etcd.io/etcd/api/v3/v3rpc/rpctypes"
     7  )
     8  
     9  func IgnoreMemberNotFound(err error) error {
    10  	if errors.Is(err, rpctypes.ErrMemberNotFound) {
    11  		return nil
    12  	}
    13  	return err
    14  }
    15  
    16  func IgnoreMemberExist(err error) error {
    17  	if errors.Is(err, rpctypes.ErrMemberExist) {
    18  		return nil
    19  	}
    20  	return err
    21  }
    22  
    23  func IgnorePeerURLExist(err error) error {
    24  	if errors.Is(err, rpctypes.ErrPeerURLExist) {
    25  		return nil
    26  	}
    27  	return err
    28  }
    29  
    30  func IgnoreTooManyLearners(err error) error {
    31  	if errors.Is(err, rpctypes.ErrTooManyLearners) {
    32  		return nil
    33  	}
    34  	return err
    35  }
    36  
    37  func IgnoreLearnerNotReady(err error) error {
    38  	if errors.Is(err, rpctypes.ErrMemberLearnerNotReady) {
    39  		return nil
    40  	}
    41  	return err
    42  }
    43  
    44  func IgnoreMemberNotLearner(err error) error {
    45  	if errors.Is(err, rpctypes.ErrMemberNotLearner) {
    46  		return nil
    47  	}
    48  	return err
    49  }
    50  

View as plain text