Showing 1,820 of 1,820 total issues
Method raftProxyResourceAllocatorServer.DetachNetwork
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyResourceAllocatorServer) DetachNetwork(ctx context.Context, r *DetachNetworkRequest) (*DetachNetworkResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method Node.MarshalToSizedBuffer
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
Method Service.MarshalToSizedBuffer
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
Method raftProxyResourceAllocatorServer.AttachNetwork
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyResourceAllocatorServer) AttachNetwork(ctx context.Context, r *AttachNetworkRequest) (*AttachNetworkResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method GetRootCACertificateRequest.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *GetRootCACertificateRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method GetUnlockKeyRequest.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *GetUnlockKeyRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method raftProxyDispatcherServer.Heartbeat
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyDispatcherServer) Heartbeat(ctx context.Context, r *HeartbeatRequest) (*HeartbeatResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method PublishLogsResponse.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *PublishLogsResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method raftProxyDispatcherServer.UpdateVolumeStatus
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyDispatcherServer) UpdateVolumeStatus(ctx context.Context, r *UpdateVolumeStatusRequest) (*UpdateVolumeStatusResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method raftProxyLogBrokerServer.PublishLogs
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyLogBrokerServer) PublishLogs(stream LogBroker_PublishLogsServer) error {
ctx := stream.Context()
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method UpdateTaskStatusResponse.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *UpdateTaskStatusResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method ListenSubscriptionsRequest.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *ListenSubscriptionsRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method UpdateVolumeStatusResponse.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *UpdateVolumeStatusResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method raftProxyDispatcherServer.UpdateTaskStatus
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyDispatcherServer) UpdateTaskStatus(ctx context.Context, r *UpdateTaskStatusRequest) (*UpdateTaskStatusResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method GlobalJob.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *GlobalJob) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method ClusterSpec.MarshalToSizedBuffer
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *ClusterSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
Method GlobalService.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *GlobalService) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method raftProxyRaftServer.ResolveAddress
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyRaftServer) ResolveAddress(ctx context.Context, r *ResolveAddressRequest) (*ResolveAddressResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {
Method ProcessRaftMessageResponse.Unmarshal
has 9 return statements (exceeds 4 allowed). Open
Open
func (m *ProcessRaftMessageResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
Method raftProxyRaftMembershipServer.Join
has 9 return statements (exceeds 4 allowed). Open
Open
func (p *raftProxyRaftMembershipServer) Join(ctx context.Context, r *JoinRequest) (*JoinResponse, error) {
conn, err := p.connSelector.LeaderConn(ctx)
if err != nil {
if err == raftselector.ErrIsLeader {