vendor: github.com/docker/swarmkit 2dcf70aafdc9ea55af3aaaeca440638cde0ecda6

full diff: 17d8d4e4d8...2dcf70aafd

Signed-off-by: Sebastiaan van Stijn <github@gone.nl>
This commit is contained in:
Sebastiaan van Stijn 2021-06-21 17:11:02 +02:00
parent f647fce891
commit 29fed6bff1
No known key found for this signature in database
GPG Key ID: 76698F39D527CE8C
15 changed files with 9249 additions and 9155 deletions

View File

@ -20,7 +20,7 @@ github.com/docker/go-connections 7395e3f8aa162843a74ed6d48e79
github.com/docker/go-events e31b211e4f1cd09aa76fe4ac244571fab96ae47f github.com/docker/go-events e31b211e4f1cd09aa76fe4ac244571fab96ae47f
github.com/docker/go-metrics b619b3592b65de4f087d9f16863a7e6ff905973c # v0.0.1 github.com/docker/go-metrics b619b3592b65de4f087d9f16863a7e6ff905973c # v0.0.1
github.com/docker/go-units 519db1ee28dcc9fd2474ae59fca29a810482bfb1 # v0.4.0 github.com/docker/go-units 519db1ee28dcc9fd2474ae59fca29a810482bfb1 # v0.4.0
github.com/docker/swarmkit 17d8d4e4d8bdec33d386e6362d3537fa9493ba00 github.com/docker/swarmkit 2dcf70aafdc9ea55af3aaaeca440638cde0ecda6 # master
github.com/evanphx/json-patch 72bf35d0ff611848c1dc9df0f976c81192392fa5 # v4.1.0 github.com/evanphx/json-patch 72bf35d0ff611848c1dc9df0f976c81192392fa5 # v4.1.0
github.com/fvbommel/sortorder 26fad50c6b32a3064c09ed089865c16f2f3615f6 # v1.0.2 github.com/fvbommel/sortorder 26fad50c6b32a3064c09ed089865c16f2f3615f6 # v1.0.2
github.com/gofrs/flock 6caa7350c26b838538005fae7dbee4e69d9398db # v0.7.3 github.com/gofrs/flock 6caa7350c26b838538005fae7dbee4e69d9398db # v0.7.3

View File

@ -18,6 +18,7 @@ import (
status "google.golang.org/grpc/status" status "google.golang.org/grpc/status"
io "io" io "io"
math "math" math "math"
math_bits "math/bits"
reflect "reflect" reflect "reflect"
strings "strings" strings "strings"
rafttime "time" rafttime "time"
@ -32,7 +33,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against. // is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the // A compilation error at this line likely means your copy of the
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type NodeCertificateStatusRequest struct { type NodeCertificateStatusRequest struct {
NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` NodeID string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
@ -51,7 +52,7 @@ func (m *NodeCertificateStatusRequest) XXX_Marshal(b []byte, deterministic bool)
return xxx_messageInfo_NodeCertificateStatusRequest.Marshal(b, m, deterministic) return xxx_messageInfo_NodeCertificateStatusRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -88,7 +89,7 @@ func (m *NodeCertificateStatusResponse) XXX_Marshal(b []byte, deterministic bool
return xxx_messageInfo_NodeCertificateStatusResponse.Marshal(b, m, deterministic) return xxx_messageInfo_NodeCertificateStatusResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -132,7 +133,7 @@ func (m *IssueNodeCertificateRequest) XXX_Marshal(b []byte, deterministic bool)
return xxx_messageInfo_IssueNodeCertificateRequest.Marshal(b, m, deterministic) return xxx_messageInfo_IssueNodeCertificateRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -169,7 +170,7 @@ func (m *IssueNodeCertificateResponse) XXX_Marshal(b []byte, deterministic bool)
return xxx_messageInfo_IssueNodeCertificateResponse.Marshal(b, m, deterministic) return xxx_messageInfo_IssueNodeCertificateResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -204,7 +205,7 @@ func (m *GetRootCACertificateRequest) XXX_Marshal(b []byte, deterministic bool)
return xxx_messageInfo_GetRootCACertificateRequest.Marshal(b, m, deterministic) return xxx_messageInfo_GetRootCACertificateRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -240,7 +241,7 @@ func (m *GetRootCACertificateResponse) XXX_Marshal(b []byte, deterministic bool)
return xxx_messageInfo_GetRootCACertificateResponse.Marshal(b, m, deterministic) return xxx_messageInfo_GetRootCACertificateResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -275,7 +276,7 @@ func (m *GetUnlockKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte,
return xxx_messageInfo_GetUnlockKeyRequest.Marshal(b, m, deterministic) return xxx_messageInfo_GetUnlockKeyRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -312,7 +313,7 @@ func (m *GetUnlockKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte
return xxx_messageInfo_GetUnlockKeyResponse.Marshal(b, m, deterministic) return xxx_messageInfo_GetUnlockKeyResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -621,6 +622,17 @@ type CAServer interface {
GetUnlockKey(context.Context, *GetUnlockKeyRequest) (*GetUnlockKeyResponse, error) GetUnlockKey(context.Context, *GetUnlockKeyRequest) (*GetUnlockKeyResponse, error)
} }
// UnimplementedCAServer can be embedded to have forward compatible implementations.
type UnimplementedCAServer struct {
}
func (*UnimplementedCAServer) GetRootCACertificate(ctx context.Context, req *GetRootCACertificateRequest) (*GetRootCACertificateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetRootCACertificate not implemented")
}
func (*UnimplementedCAServer) GetUnlockKey(ctx context.Context, req *GetUnlockKeyRequest) (*GetUnlockKeyResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method GetUnlockKey not implemented")
}
func RegisterCAServer(s *grpc.Server, srv CAServer) { func RegisterCAServer(s *grpc.Server, srv CAServer) {
s.RegisterService(&_CA_serviceDesc, srv) s.RegisterService(&_CA_serviceDesc, srv)
} }
@ -718,6 +730,17 @@ type NodeCAServer interface {
NodeCertificateStatus(context.Context, *NodeCertificateStatusRequest) (*NodeCertificateStatusResponse, error) NodeCertificateStatus(context.Context, *NodeCertificateStatusRequest) (*NodeCertificateStatusResponse, error)
} }
// UnimplementedNodeCAServer can be embedded to have forward compatible implementations.
type UnimplementedNodeCAServer struct {
}
func (*UnimplementedNodeCAServer) IssueNodeCertificate(ctx context.Context, req *IssueNodeCertificateRequest) (*IssueNodeCertificateResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method IssueNodeCertificate not implemented")
}
func (*UnimplementedNodeCAServer) NodeCertificateStatus(ctx context.Context, req *NodeCertificateStatusRequest) (*NodeCertificateStatusResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method NodeCertificateStatus not implemented")
}
func RegisterNodeCAServer(s *grpc.Server, srv NodeCAServer) { func RegisterNodeCAServer(s *grpc.Server, srv NodeCAServer) {
s.RegisterService(&_NodeCA_serviceDesc, srv) s.RegisterService(&_NodeCA_serviceDesc, srv)
} }
@ -778,7 +801,7 @@ var _NodeCA_serviceDesc = grpc.ServiceDesc{
func (m *NodeCertificateStatusRequest) Marshal() (dAtA []byte, err error) { func (m *NodeCertificateStatusRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -786,23 +809,29 @@ func (m *NodeCertificateStatusRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *NodeCertificateStatusRequest) MarshalTo(dAtA []byte) (int, error) { func (m *NodeCertificateStatusRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *NodeCertificateStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.NodeID) > 0 { if len(m.NodeID) > 0 {
dAtA[i] = 0xa i -= len(m.NodeID)
i++ copy(dAtA[i:], m.NodeID)
i = encodeVarintCa(dAtA, i, uint64(len(m.NodeID))) i = encodeVarintCa(dAtA, i, uint64(len(m.NodeID)))
i += copy(dAtA[i:], m.NodeID) i--
dAtA[i] = 0xa
} }
return i, nil return len(dAtA) - i, nil
} }
func (m *NodeCertificateStatusResponse) Marshal() (dAtA []byte, err error) { func (m *NodeCertificateStatusResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -810,37 +839,46 @@ func (m *NodeCertificateStatusResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *NodeCertificateStatusResponse) MarshalTo(dAtA []byte) (int, error) { func (m *NodeCertificateStatusResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *NodeCertificateStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.Status != nil {
dAtA[i] = 0xa
i++
i = encodeVarintCa(dAtA, i, uint64(m.Status.Size()))
n1, err := m.Status.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
}
if m.Certificate != nil { if m.Certificate != nil {
dAtA[i] = 0x12 {
i++ size, err := m.Certificate.MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintCa(dAtA, i, uint64(m.Certificate.Size())) if err != nil {
n2, err := m.Certificate.MarshalTo(dAtA[i:]) return 0, err
if err != nil { }
return 0, err i -= size
i = encodeVarintCa(dAtA, i, uint64(size))
} }
i += n2 i--
dAtA[i] = 0x12
} }
return i, nil if m.Status != nil {
{
size, err := m.Status.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintCa(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
} }
func (m *IssueNodeCertificateRequest) Marshal() (dAtA []byte, err error) { func (m *IssueNodeCertificateRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -848,39 +886,46 @@ func (m *IssueNodeCertificateRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *IssueNodeCertificateRequest) MarshalTo(dAtA []byte) (int, error) { func (m *IssueNodeCertificateRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *IssueNodeCertificateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.Role != 0 { if m.Availability != 0 {
dAtA[i] = 0x8 i = encodeVarintCa(dAtA, i, uint64(m.Availability))
i++ i--
i = encodeVarintCa(dAtA, i, uint64(m.Role)) dAtA[i] = 0x20
}
if len(m.CSR) > 0 {
dAtA[i] = 0x12
i++
i = encodeVarintCa(dAtA, i, uint64(len(m.CSR)))
i += copy(dAtA[i:], m.CSR)
} }
if len(m.Token) > 0 { if len(m.Token) > 0 {
dAtA[i] = 0x1a i -= len(m.Token)
i++ copy(dAtA[i:], m.Token)
i = encodeVarintCa(dAtA, i, uint64(len(m.Token))) i = encodeVarintCa(dAtA, i, uint64(len(m.Token)))
i += copy(dAtA[i:], m.Token) i--
dAtA[i] = 0x1a
} }
if m.Availability != 0 { if len(m.CSR) > 0 {
dAtA[i] = 0x20 i -= len(m.CSR)
i++ copy(dAtA[i:], m.CSR)
i = encodeVarintCa(dAtA, i, uint64(m.Availability)) i = encodeVarintCa(dAtA, i, uint64(len(m.CSR)))
i--
dAtA[i] = 0x12
} }
return i, nil if m.Role != 0 {
i = encodeVarintCa(dAtA, i, uint64(m.Role))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
} }
func (m *IssueNodeCertificateResponse) Marshal() (dAtA []byte, err error) { func (m *IssueNodeCertificateResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -888,28 +933,34 @@ func (m *IssueNodeCertificateResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *IssueNodeCertificateResponse) MarshalTo(dAtA []byte) (int, error) { func (m *IssueNodeCertificateResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *IssueNodeCertificateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.NodeID) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintCa(dAtA, i, uint64(len(m.NodeID)))
i += copy(dAtA[i:], m.NodeID)
}
if m.NodeMembership != 0 { if m.NodeMembership != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintCa(dAtA, i, uint64(m.NodeMembership)) i = encodeVarintCa(dAtA, i, uint64(m.NodeMembership))
i--
dAtA[i] = 0x10
} }
return i, nil if len(m.NodeID) > 0 {
i -= len(m.NodeID)
copy(dAtA[i:], m.NodeID)
i = encodeVarintCa(dAtA, i, uint64(len(m.NodeID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
} }
func (m *GetRootCACertificateRequest) Marshal() (dAtA []byte, err error) { func (m *GetRootCACertificateRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -917,17 +968,22 @@ func (m *GetRootCACertificateRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *GetRootCACertificateRequest) MarshalTo(dAtA []byte) (int, error) { func (m *GetRootCACertificateRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *GetRootCACertificateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
return i, nil return len(dAtA) - i, nil
} }
func (m *GetRootCACertificateResponse) Marshal() (dAtA []byte, err error) { func (m *GetRootCACertificateResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -935,23 +991,29 @@ func (m *GetRootCACertificateResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *GetRootCACertificateResponse) MarshalTo(dAtA []byte) (int, error) { func (m *GetRootCACertificateResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *GetRootCACertificateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Certificate) > 0 { if len(m.Certificate) > 0 {
dAtA[i] = 0xa i -= len(m.Certificate)
i++ copy(dAtA[i:], m.Certificate)
i = encodeVarintCa(dAtA, i, uint64(len(m.Certificate))) i = encodeVarintCa(dAtA, i, uint64(len(m.Certificate)))
i += copy(dAtA[i:], m.Certificate) i--
dAtA[i] = 0xa
} }
return i, nil return len(dAtA) - i, nil
} }
func (m *GetUnlockKeyRequest) Marshal() (dAtA []byte, err error) { func (m *GetUnlockKeyRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -959,17 +1021,22 @@ func (m *GetUnlockKeyRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *GetUnlockKeyRequest) MarshalTo(dAtA []byte) (int, error) { func (m *GetUnlockKeyRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *GetUnlockKeyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
return i, nil return len(dAtA) - i, nil
} }
func (m *GetUnlockKeyResponse) Marshal() (dAtA []byte, err error) { func (m *GetUnlockKeyResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -977,35 +1044,45 @@ func (m *GetUnlockKeyResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *GetUnlockKeyResponse) MarshalTo(dAtA []byte) (int, error) { func (m *GetUnlockKeyResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *GetUnlockKeyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.UnlockKey) > 0 { {
dAtA[i] = 0xa size, err := m.Version.MarshalToSizedBuffer(dAtA[:i])
i++ if err != nil {
i = encodeVarintCa(dAtA, i, uint64(len(m.UnlockKey))) return 0, err
i += copy(dAtA[i:], m.UnlockKey) }
i -= size
i = encodeVarintCa(dAtA, i, uint64(size))
} }
i--
dAtA[i] = 0x12 dAtA[i] = 0x12
i++ if len(m.UnlockKey) > 0 {
i = encodeVarintCa(dAtA, i, uint64(m.Version.Size())) i -= len(m.UnlockKey)
n3, err := m.Version.MarshalTo(dAtA[i:]) copy(dAtA[i:], m.UnlockKey)
if err != nil { i = encodeVarintCa(dAtA, i, uint64(len(m.UnlockKey)))
return 0, err i--
dAtA[i] = 0xa
} }
i += n3 return len(dAtA) - i, nil
return i, nil
} }
func encodeVarintCa(dAtA []byte, offset int, v uint64) int { func encodeVarintCa(dAtA []byte, offset int, v uint64) int {
offset -= sovCa(v)
base := offset
for v >= 1<<7 { for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80) dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7 v >>= 7
offset++ offset++
} }
dAtA[offset] = uint8(v) dAtA[offset] = uint8(v)
return offset + 1 return base
} }
type raftProxyCAServer struct { type raftProxyCAServer struct {
@ -1408,14 +1485,7 @@ func (m *GetUnlockKeyResponse) Size() (n int) {
} }
func sovCa(x uint64) (n int) { func sovCa(x uint64) (n int) {
for { return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
} }
func sozCa(x uint64) (n int) { func sozCa(x uint64) (n int) {
return sovCa(uint64((x << 1) ^ uint64((int64(x) >> 63)))) return sovCa(uint64((x << 1) ^ uint64((int64(x) >> 63))))
@ -1499,7 +1569,7 @@ func (this *GetUnlockKeyResponse) String() string {
} }
s := strings.Join([]string{`&GetUnlockKeyResponse{`, s := strings.Join([]string{`&GetUnlockKeyResponse{`,
`UnlockKey:` + fmt.Sprintf("%v", this.UnlockKey) + `,`, `UnlockKey:` + fmt.Sprintf("%v", this.UnlockKey) + `,`,
`Version:` + strings.Replace(strings.Replace(this.Version.String(), "Version", "Version", 1), `&`, ``, 1) + `,`, `Version:` + strings.Replace(strings.Replace(fmt.Sprintf("%v", this.Version), "Version", "Version", 1), `&`, ``, 1) + `,`,
`}`, `}`,
}, "") }, "")
return s return s
@ -1579,10 +1649,7 @@ func (m *NodeCertificateStatusRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1704,10 +1771,7 @@ func (m *NodeCertificateStatusResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1861,10 +1925,7 @@ func (m *IssueNodeCertificateRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1965,10 +2026,7 @@ func (m *IssueNodeCertificateResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -2018,10 +2076,7 @@ func (m *GetRootCACertificateRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -2105,10 +2160,7 @@ func (m *GetRootCACertificateResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -2158,10 +2210,7 @@ func (m *GetUnlockKeyRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -2278,10 +2327,7 @@ func (m *GetUnlockKeyResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthCa
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthCa return ErrInvalidLengthCa
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -2299,6 +2345,7 @@ func (m *GetUnlockKeyResponse) Unmarshal(dAtA []byte) error {
func skipCa(dAtA []byte) (n int, err error) { func skipCa(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
depth := 0
for iNdEx < l { for iNdEx < l {
var wire uint64 var wire uint64
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -2330,10 +2377,8 @@ func skipCa(dAtA []byte) (n int, err error) {
break break
} }
} }
return iNdEx, nil
case 1: case 1:
iNdEx += 8 iNdEx += 8
return iNdEx, nil
case 2: case 2:
var length int var length int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -2354,55 +2399,30 @@ func skipCa(dAtA []byte) (n int, err error) {
return 0, ErrInvalidLengthCa return 0, ErrInvalidLengthCa
} }
iNdEx += length iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthCa
}
return iNdEx, nil
case 3: case 3:
for { depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowCa
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipCa(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthCa
}
}
return iNdEx, nil
case 4: case 4:
return iNdEx, nil if depth == 0 {
return 0, ErrUnexpectedEndOfGroupCa
}
depth--
case 5: case 5:
iNdEx += 4 iNdEx += 4
return iNdEx, nil
default: default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType) return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
} }
if iNdEx < 0 {
return 0, ErrInvalidLengthCa
}
if depth == 0 {
return iNdEx, nil
}
} }
panic("unreachable") return 0, io.ErrUnexpectedEOF
} }
var ( var (
ErrInvalidLengthCa = fmt.Errorf("proto: negative length found during unmarshaling") ErrInvalidLengthCa = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowCa = fmt.Errorf("proto: integer overflow") ErrIntOverflowCa = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupCa = fmt.Errorf("proto: unexpected end of group")
) )

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -17,6 +17,7 @@ import (
status "google.golang.org/grpc/status" status "google.golang.org/grpc/status"
io "io" io "io"
math "math" math "math"
math_bits "math/bits"
reflect "reflect" reflect "reflect"
strings "strings" strings "strings"
rafttime "time" rafttime "time"
@ -31,7 +32,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against. // is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the // A compilation error at this line likely means your copy of the
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type HealthCheckResponse_ServingStatus int32 type HealthCheckResponse_ServingStatus int32
@ -78,7 +79,7 @@ func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte,
return xxx_messageInfo_HealthCheckRequest.Marshal(b, m, deterministic) return xxx_messageInfo_HealthCheckRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -114,7 +115,7 @@ func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte,
return xxx_messageInfo_HealthCheckResponse.Marshal(b, m, deterministic) return xxx_messageInfo_HealthCheckResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -255,6 +256,14 @@ type HealthServer interface {
Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error) Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
} }
// UnimplementedHealthServer can be embedded to have forward compatible implementations.
type UnimplementedHealthServer struct {
}
func (*UnimplementedHealthServer) Check(ctx context.Context, req *HealthCheckRequest) (*HealthCheckResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Check not implemented")
}
func RegisterHealthServer(s *grpc.Server, srv HealthServer) { func RegisterHealthServer(s *grpc.Server, srv HealthServer) {
s.RegisterService(&_Health_serviceDesc, srv) s.RegisterService(&_Health_serviceDesc, srv)
} }
@ -293,7 +302,7 @@ var _Health_serviceDesc = grpc.ServiceDesc{
func (m *HealthCheckRequest) Marshal() (dAtA []byte, err error) { func (m *HealthCheckRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -301,23 +310,29 @@ func (m *HealthCheckRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *HealthCheckRequest) MarshalTo(dAtA []byte) (int, error) { func (m *HealthCheckRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *HealthCheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Service) > 0 { if len(m.Service) > 0 {
dAtA[i] = 0xa i -= len(m.Service)
i++ copy(dAtA[i:], m.Service)
i = encodeVarintHealth(dAtA, i, uint64(len(m.Service))) i = encodeVarintHealth(dAtA, i, uint64(len(m.Service)))
i += copy(dAtA[i:], m.Service) i--
dAtA[i] = 0xa
} }
return i, nil return len(dAtA) - i, nil
} }
func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error) { func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -325,26 +340,33 @@ func (m *HealthCheckResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error) { func (m *HealthCheckResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *HealthCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.Status != 0 { if m.Status != 0 {
dAtA[i] = 0x8
i++
i = encodeVarintHealth(dAtA, i, uint64(m.Status)) i = encodeVarintHealth(dAtA, i, uint64(m.Status))
i--
dAtA[i] = 0x8
} }
return i, nil return len(dAtA) - i, nil
} }
func encodeVarintHealth(dAtA []byte, offset int, v uint64) int { func encodeVarintHealth(dAtA []byte, offset int, v uint64) int {
offset -= sovHealth(v)
base := offset
for v >= 1<<7 { for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80) dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7 v >>= 7
offset++ offset++
} }
dAtA[offset] = uint8(v) dAtA[offset] = uint8(v)
return offset + 1 return base
} }
type raftProxyHealthServer struct { type raftProxyHealthServer struct {
@ -480,14 +502,7 @@ func (m *HealthCheckResponse) Size() (n int) {
} }
func sovHealth(x uint64) (n int) { func sovHealth(x uint64) (n int) {
for { return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
} }
func sozHealth(x uint64) (n int) { func sozHealth(x uint64) (n int) {
return sovHealth(uint64((x << 1) ^ uint64((int64(x) >> 63)))) return sovHealth(uint64((x << 1) ^ uint64((int64(x) >> 63))))
@ -587,10 +602,7 @@ func (m *HealthCheckRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthHealth
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthHealth return ErrInvalidLengthHealth
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -659,10 +671,7 @@ func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthHealth
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthHealth return ErrInvalidLengthHealth
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -680,6 +689,7 @@ func (m *HealthCheckResponse) Unmarshal(dAtA []byte) error {
func skipHealth(dAtA []byte) (n int, err error) { func skipHealth(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
depth := 0
for iNdEx < l { for iNdEx < l {
var wire uint64 var wire uint64
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -711,10 +721,8 @@ func skipHealth(dAtA []byte) (n int, err error) {
break break
} }
} }
return iNdEx, nil
case 1: case 1:
iNdEx += 8 iNdEx += 8
return iNdEx, nil
case 2: case 2:
var length int var length int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -735,55 +743,30 @@ func skipHealth(dAtA []byte) (n int, err error) {
return 0, ErrInvalidLengthHealth return 0, ErrInvalidLengthHealth
} }
iNdEx += length iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthHealth
}
return iNdEx, nil
case 3: case 3:
for { depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowHealth
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipHealth(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthHealth
}
}
return iNdEx, nil
case 4: case 4:
return iNdEx, nil if depth == 0 {
return 0, ErrUnexpectedEndOfGroupHealth
}
depth--
case 5: case 5:
iNdEx += 4 iNdEx += 4
return iNdEx, nil
default: default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType) return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
} }
if iNdEx < 0 {
return 0, ErrInvalidLengthHealth
}
if depth == 0 {
return iNdEx, nil
}
} }
panic("unreachable") return 0, io.ErrUnexpectedEOF
} }
var ( var (
ErrInvalidLengthHealth = fmt.Errorf("proto: negative length found during unmarshaling") ErrInvalidLengthHealth = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowHealth = fmt.Errorf("proto: integer overflow") ErrIntOverflowHealth = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupHealth = fmt.Errorf("proto: unexpected end of group")
) )

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -18,6 +18,7 @@ import (
status "google.golang.org/grpc/status" status "google.golang.org/grpc/status"
io "io" io "io"
math "math" math "math"
math_bits "math/bits"
reflect "reflect" reflect "reflect"
strings "strings" strings "strings"
rafttime "time" rafttime "time"
@ -32,7 +33,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against. // is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the // A compilation error at this line likely means your copy of the
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type AttachNetworkRequest struct { type AttachNetworkRequest struct {
Config *NetworkAttachmentConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` Config *NetworkAttachmentConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
@ -52,7 +53,7 @@ func (m *AttachNetworkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte
return xxx_messageInfo_AttachNetworkRequest.Marshal(b, m, deterministic) return xxx_messageInfo_AttachNetworkRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -88,7 +89,7 @@ func (m *AttachNetworkResponse) XXX_Marshal(b []byte, deterministic bool) ([]byt
return xxx_messageInfo_AttachNetworkResponse.Marshal(b, m, deterministic) return xxx_messageInfo_AttachNetworkResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -124,7 +125,7 @@ func (m *DetachNetworkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte
return xxx_messageInfo_DetachNetworkRequest.Marshal(b, m, deterministic) return xxx_messageInfo_DetachNetworkRequest.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -159,7 +160,7 @@ func (m *DetachNetworkResponse) XXX_Marshal(b []byte, deterministic bool) ([]byt
return xxx_messageInfo_DetachNetworkResponse.Marshal(b, m, deterministic) return xxx_messageInfo_DetachNetworkResponse.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -355,6 +356,17 @@ type ResourceAllocatorServer interface {
DetachNetwork(context.Context, *DetachNetworkRequest) (*DetachNetworkResponse, error) DetachNetwork(context.Context, *DetachNetworkRequest) (*DetachNetworkResponse, error)
} }
// UnimplementedResourceAllocatorServer can be embedded to have forward compatible implementations.
type UnimplementedResourceAllocatorServer struct {
}
func (*UnimplementedResourceAllocatorServer) AttachNetwork(ctx context.Context, req *AttachNetworkRequest) (*AttachNetworkResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method AttachNetwork not implemented")
}
func (*UnimplementedResourceAllocatorServer) DetachNetwork(ctx context.Context, req *DetachNetworkRequest) (*DetachNetworkResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method DetachNetwork not implemented")
}
func RegisterResourceAllocatorServer(s *grpc.Server, srv ResourceAllocatorServer) { func RegisterResourceAllocatorServer(s *grpc.Server, srv ResourceAllocatorServer) {
s.RegisterService(&_ResourceAllocator_serviceDesc, srv) s.RegisterService(&_ResourceAllocator_serviceDesc, srv)
} }
@ -415,7 +427,7 @@ var _ResourceAllocator_serviceDesc = grpc.ServiceDesc{
func (m *AttachNetworkRequest) Marshal() (dAtA []byte, err error) { func (m *AttachNetworkRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -423,33 +435,41 @@ func (m *AttachNetworkRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *AttachNetworkRequest) MarshalTo(dAtA []byte) (int, error) { func (m *AttachNetworkRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *AttachNetworkRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.Config != nil {
dAtA[i] = 0xa
i++
i = encodeVarintResource(dAtA, i, uint64(m.Config.Size()))
n1, err := m.Config.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
}
if len(m.ContainerID) > 0 { if len(m.ContainerID) > 0 {
dAtA[i] = 0x12 i -= len(m.ContainerID)
i++ copy(dAtA[i:], m.ContainerID)
i = encodeVarintResource(dAtA, i, uint64(len(m.ContainerID))) i = encodeVarintResource(dAtA, i, uint64(len(m.ContainerID)))
i += copy(dAtA[i:], m.ContainerID) i--
dAtA[i] = 0x12
} }
return i, nil if m.Config != nil {
{
size, err := m.Config.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintResource(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
} }
func (m *AttachNetworkResponse) Marshal() (dAtA []byte, err error) { func (m *AttachNetworkResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -457,23 +477,29 @@ func (m *AttachNetworkResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *AttachNetworkResponse) MarshalTo(dAtA []byte) (int, error) { func (m *AttachNetworkResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *AttachNetworkResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.AttachmentID) > 0 { if len(m.AttachmentID) > 0 {
dAtA[i] = 0xa i -= len(m.AttachmentID)
i++ copy(dAtA[i:], m.AttachmentID)
i = encodeVarintResource(dAtA, i, uint64(len(m.AttachmentID))) i = encodeVarintResource(dAtA, i, uint64(len(m.AttachmentID)))
i += copy(dAtA[i:], m.AttachmentID) i--
dAtA[i] = 0xa
} }
return i, nil return len(dAtA) - i, nil
} }
func (m *DetachNetworkRequest) Marshal() (dAtA []byte, err error) { func (m *DetachNetworkRequest) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -481,23 +507,29 @@ func (m *DetachNetworkRequest) Marshal() (dAtA []byte, err error) {
} }
func (m *DetachNetworkRequest) MarshalTo(dAtA []byte) (int, error) { func (m *DetachNetworkRequest) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *DetachNetworkRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.AttachmentID) > 0 { if len(m.AttachmentID) > 0 {
dAtA[i] = 0xa i -= len(m.AttachmentID)
i++ copy(dAtA[i:], m.AttachmentID)
i = encodeVarintResource(dAtA, i, uint64(len(m.AttachmentID))) i = encodeVarintResource(dAtA, i, uint64(len(m.AttachmentID)))
i += copy(dAtA[i:], m.AttachmentID) i--
dAtA[i] = 0xa
} }
return i, nil return len(dAtA) - i, nil
} }
func (m *DetachNetworkResponse) Marshal() (dAtA []byte, err error) { func (m *DetachNetworkResponse) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -505,21 +537,28 @@ func (m *DetachNetworkResponse) Marshal() (dAtA []byte, err error) {
} }
func (m *DetachNetworkResponse) MarshalTo(dAtA []byte) (int, error) { func (m *DetachNetworkResponse) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *DetachNetworkResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
return i, nil return len(dAtA) - i, nil
} }
func encodeVarintResource(dAtA []byte, offset int, v uint64) int { func encodeVarintResource(dAtA []byte, offset int, v uint64) int {
offset -= sovResource(v)
base := offset
for v >= 1<<7 { for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80) dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7 v >>= 7
offset++ offset++
} }
dAtA[offset] = uint8(v) dAtA[offset] = uint8(v)
return offset + 1 return base
} }
type raftProxyResourceAllocatorServer struct { type raftProxyResourceAllocatorServer struct {
@ -717,14 +756,7 @@ func (m *DetachNetworkResponse) Size() (n int) {
} }
func sovResource(x uint64) (n int) { func sovResource(x uint64) (n int) {
for { return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
} }
func sozResource(x uint64) (n int) { func sozResource(x uint64) (n int) {
return sovResource(uint64((x << 1) ^ uint64((int64(x) >> 63)))) return sovResource(uint64((x << 1) ^ uint64((int64(x) >> 63))))
@ -880,10 +912,7 @@ func (m *AttachNetworkRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthResource
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthResource return ErrInvalidLengthResource
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -965,10 +994,7 @@ func (m *AttachNetworkResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthResource
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthResource return ErrInvalidLengthResource
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1050,10 +1076,7 @@ func (m *DetachNetworkRequest) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthResource
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthResource return ErrInvalidLengthResource
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1103,10 +1126,7 @@ func (m *DetachNetworkResponse) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthResource
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthResource return ErrInvalidLengthResource
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1124,6 +1144,7 @@ func (m *DetachNetworkResponse) Unmarshal(dAtA []byte) error {
func skipResource(dAtA []byte) (n int, err error) { func skipResource(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
depth := 0
for iNdEx < l { for iNdEx < l {
var wire uint64 var wire uint64
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -1155,10 +1176,8 @@ func skipResource(dAtA []byte) (n int, err error) {
break break
} }
} }
return iNdEx, nil
case 1: case 1:
iNdEx += 8 iNdEx += 8
return iNdEx, nil
case 2: case 2:
var length int var length int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -1179,55 +1198,30 @@ func skipResource(dAtA []byte) (n int, err error) {
return 0, ErrInvalidLengthResource return 0, ErrInvalidLengthResource
} }
iNdEx += length iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthResource
}
return iNdEx, nil
case 3: case 3:
for { depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowResource
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipResource(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthResource
}
}
return iNdEx, nil
case 4: case 4:
return iNdEx, nil if depth == 0 {
return 0, ErrUnexpectedEndOfGroupResource
}
depth--
case 5: case 5:
iNdEx += 4 iNdEx += 4
return iNdEx, nil
default: default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType) return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
} }
if iNdEx < 0 {
return 0, ErrInvalidLengthResource
}
if depth == 0 {
return iNdEx, nil
}
} }
panic("unreachable") return 0, io.ErrUnexpectedEOF
} }
var ( var (
ErrInvalidLengthResource = fmt.Errorf("proto: negative length found during unmarshaling") ErrInvalidLengthResource = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowResource = fmt.Errorf("proto: integer overflow") ErrIntOverflowResource = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupResource = fmt.Errorf("proto: unexpected end of group")
) )

View File

@ -9,6 +9,7 @@ import (
proto "github.com/gogo/protobuf/proto" proto "github.com/gogo/protobuf/proto"
io "io" io "io"
math "math" math "math"
math_bits "math/bits"
reflect "reflect" reflect "reflect"
strings "strings" strings "strings"
) )
@ -22,7 +23,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against. // is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the // A compilation error at this line likely means your copy of the
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type Snapshot_Version int32 type Snapshot_Version int32
@ -73,7 +74,7 @@ func (m *StoreSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error
return xxx_messageInfo_StoreSnapshot.Marshal(b, m, deterministic) return xxx_messageInfo_StoreSnapshot.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -111,7 +112,7 @@ func (m *ClusterSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, err
return xxx_messageInfo_ClusterSnapshot.Marshal(b, m, deterministic) return xxx_messageInfo_ClusterSnapshot.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -149,7 +150,7 @@ func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Snapshot.Marshal(b, m, deterministic) return xxx_messageInfo_Snapshot.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -350,7 +351,7 @@ func (m *Snapshot) CopyFrom(src interface{}) {
func (m *StoreSnapshot) Marshal() (dAtA []byte, err error) { func (m *StoreSnapshot) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -358,125 +359,148 @@ func (m *StoreSnapshot) Marshal() (dAtA []byte, err error) {
} }
func (m *StoreSnapshot) MarshalTo(dAtA []byte) (int, error) { func (m *StoreSnapshot) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *StoreSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Nodes) > 0 { if len(m.Configs) > 0 {
for _, msg := range m.Nodes { for iNdEx := len(m.Configs) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0xa {
i++ size, err := m.Configs[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size())) if err != nil {
n, err := msg.MarshalTo(dAtA[i:]) return 0, err
if err != nil { }
return 0, err i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
} }
i += n i--
} dAtA[i] = 0x4a
}
if len(m.Services) > 0 {
for _, msg := range m.Services {
dAtA[i] = 0x12
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Networks) > 0 {
for _, msg := range m.Networks {
dAtA[i] = 0x1a
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Tasks) > 0 {
for _, msg := range m.Tasks {
dAtA[i] = 0x22
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Clusters) > 0 {
for _, msg := range m.Clusters {
dAtA[i] = 0x2a
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Secrets) > 0 {
for _, msg := range m.Secrets {
dAtA[i] = 0x32
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Resources) > 0 {
for _, msg := range m.Resources {
dAtA[i] = 0x3a
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
} }
} }
if len(m.Extensions) > 0 { if len(m.Extensions) > 0 {
for _, msg := range m.Extensions { for iNdEx := len(m.Extensions) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Extensions[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x42 dAtA[i] = 0x42
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
} }
} }
if len(m.Configs) > 0 { if len(m.Resources) > 0 {
for _, msg := range m.Configs { for iNdEx := len(m.Resources) - 1; iNdEx >= 0; iNdEx-- {
dAtA[i] = 0x4a {
i++ size, err := m.Resources[iNdEx].MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size())) if err != nil {
n, err := msg.MarshalTo(dAtA[i:]) return 0, err
if err != nil { }
return 0, err i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
} }
i += n i--
dAtA[i] = 0x3a
} }
} }
return i, nil if len(m.Secrets) > 0 {
for iNdEx := len(m.Secrets) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Secrets[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x32
}
}
if len(m.Clusters) > 0 {
for iNdEx := len(m.Clusters) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Clusters[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x2a
}
}
if len(m.Tasks) > 0 {
for iNdEx := len(m.Tasks) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Tasks[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x22
}
}
if len(m.Networks) > 0 {
for iNdEx := len(m.Networks) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Networks[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1a
}
}
if len(m.Services) > 0 {
for iNdEx := len(m.Services) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Services[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
}
if len(m.Nodes) > 0 {
for iNdEx := len(m.Nodes) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Nodes[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
} }
func (m *ClusterSnapshot) Marshal() (dAtA []byte, err error) { func (m *ClusterSnapshot) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -484,36 +508,43 @@ func (m *ClusterSnapshot) Marshal() (dAtA []byte, err error) {
} }
func (m *ClusterSnapshot) MarshalTo(dAtA []byte) (int, error) { func (m *ClusterSnapshot) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *ClusterSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Members) > 0 {
for _, msg := range m.Members {
dAtA[i] = 0xa
i++
i = encodeVarintSnapshot(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Removed) > 0 { if len(m.Removed) > 0 {
for _, num := range m.Removed { for iNdEx := len(m.Removed) - 1; iNdEx >= 0; iNdEx-- {
i = encodeVarintSnapshot(dAtA, i, uint64(m.Removed[iNdEx]))
i--
dAtA[i] = 0x10 dAtA[i] = 0x10
i++
i = encodeVarintSnapshot(dAtA, i, uint64(num))
} }
} }
return i, nil if len(m.Members) > 0 {
for iNdEx := len(m.Members) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Members[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
} }
func (m *Snapshot) Marshal() (dAtA []byte, err error) { func (m *Snapshot) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -521,42 +552,53 @@ func (m *Snapshot) Marshal() (dAtA []byte, err error) {
} }
func (m *Snapshot) MarshalTo(dAtA []byte) (int, error) { func (m *Snapshot) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *Snapshot) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.Version != 0 { {
dAtA[i] = 0x8 size, err := m.Store.MarshalToSizedBuffer(dAtA[:i])
i++ if err != nil {
i = encodeVarintSnapshot(dAtA, i, uint64(m.Version)) return 0, err
}
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
} }
dAtA[i] = 0x12 i--
i++
i = encodeVarintSnapshot(dAtA, i, uint64(m.Membership.Size()))
n1, err := m.Membership.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
dAtA[i] = 0x1a dAtA[i] = 0x1a
i++ {
i = encodeVarintSnapshot(dAtA, i, uint64(m.Store.Size())) size, err := m.Membership.MarshalToSizedBuffer(dAtA[:i])
n2, err := m.Store.MarshalTo(dAtA[i:]) if err != nil {
if err != nil { return 0, err
return 0, err }
i -= size
i = encodeVarintSnapshot(dAtA, i, uint64(size))
} }
i += n2 i--
return i, nil dAtA[i] = 0x12
if m.Version != 0 {
i = encodeVarintSnapshot(dAtA, i, uint64(m.Version))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
} }
func encodeVarintSnapshot(dAtA []byte, offset int, v uint64) int { func encodeVarintSnapshot(dAtA []byte, offset int, v uint64) int {
offset -= sovSnapshot(v)
base := offset
for v >= 1<<7 { for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80) dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7 v >>= 7
offset++ offset++
} }
dAtA[offset] = uint8(v) dAtA[offset] = uint8(v)
return offset + 1 return base
} }
func (m *StoreSnapshot) Size() (n int) { func (m *StoreSnapshot) Size() (n int) {
if m == nil { if m == nil {
@ -658,14 +700,7 @@ func (m *Snapshot) Size() (n int) {
} }
func sovSnapshot(x uint64) (n int) { func sovSnapshot(x uint64) (n int) {
for { return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
} }
func sozSnapshot(x uint64) (n int) { func sozSnapshot(x uint64) (n int) {
return sovSnapshot(uint64((x << 1) ^ uint64((int64(x) >> 63)))) return sovSnapshot(uint64((x << 1) ^ uint64((int64(x) >> 63))))
@ -674,16 +709,61 @@ func (this *StoreSnapshot) String() string {
if this == nil { if this == nil {
return "nil" return "nil"
} }
repeatedStringForNodes := "[]*Node{"
for _, f := range this.Nodes {
repeatedStringForNodes += strings.Replace(fmt.Sprintf("%v", f), "Node", "Node", 1) + ","
}
repeatedStringForNodes += "}"
repeatedStringForServices := "[]*Service{"
for _, f := range this.Services {
repeatedStringForServices += strings.Replace(fmt.Sprintf("%v", f), "Service", "Service", 1) + ","
}
repeatedStringForServices += "}"
repeatedStringForNetworks := "[]*Network{"
for _, f := range this.Networks {
repeatedStringForNetworks += strings.Replace(fmt.Sprintf("%v", f), "Network", "Network", 1) + ","
}
repeatedStringForNetworks += "}"
repeatedStringForTasks := "[]*Task{"
for _, f := range this.Tasks {
repeatedStringForTasks += strings.Replace(fmt.Sprintf("%v", f), "Task", "Task", 1) + ","
}
repeatedStringForTasks += "}"
repeatedStringForClusters := "[]*Cluster{"
for _, f := range this.Clusters {
repeatedStringForClusters += strings.Replace(fmt.Sprintf("%v", f), "Cluster", "Cluster", 1) + ","
}
repeatedStringForClusters += "}"
repeatedStringForSecrets := "[]*Secret{"
for _, f := range this.Secrets {
repeatedStringForSecrets += strings.Replace(fmt.Sprintf("%v", f), "Secret", "Secret", 1) + ","
}
repeatedStringForSecrets += "}"
repeatedStringForResources := "[]*Resource{"
for _, f := range this.Resources {
repeatedStringForResources += strings.Replace(fmt.Sprintf("%v", f), "Resource", "Resource", 1) + ","
}
repeatedStringForResources += "}"
repeatedStringForExtensions := "[]*Extension{"
for _, f := range this.Extensions {
repeatedStringForExtensions += strings.Replace(fmt.Sprintf("%v", f), "Extension", "Extension", 1) + ","
}
repeatedStringForExtensions += "}"
repeatedStringForConfigs := "[]*Config{"
for _, f := range this.Configs {
repeatedStringForConfigs += strings.Replace(fmt.Sprintf("%v", f), "Config", "Config", 1) + ","
}
repeatedStringForConfigs += "}"
s := strings.Join([]string{`&StoreSnapshot{`, s := strings.Join([]string{`&StoreSnapshot{`,
`Nodes:` + strings.Replace(fmt.Sprintf("%v", this.Nodes), "Node", "Node", 1) + `,`, `Nodes:` + repeatedStringForNodes + `,`,
`Services:` + strings.Replace(fmt.Sprintf("%v", this.Services), "Service", "Service", 1) + `,`, `Services:` + repeatedStringForServices + `,`,
`Networks:` + strings.Replace(fmt.Sprintf("%v", this.Networks), "Network", "Network", 1) + `,`, `Networks:` + repeatedStringForNetworks + `,`,
`Tasks:` + strings.Replace(fmt.Sprintf("%v", this.Tasks), "Task", "Task", 1) + `,`, `Tasks:` + repeatedStringForTasks + `,`,
`Clusters:` + strings.Replace(fmt.Sprintf("%v", this.Clusters), "Cluster", "Cluster", 1) + `,`, `Clusters:` + repeatedStringForClusters + `,`,
`Secrets:` + strings.Replace(fmt.Sprintf("%v", this.Secrets), "Secret", "Secret", 1) + `,`, `Secrets:` + repeatedStringForSecrets + `,`,
`Resources:` + strings.Replace(fmt.Sprintf("%v", this.Resources), "Resource", "Resource", 1) + `,`, `Resources:` + repeatedStringForResources + `,`,
`Extensions:` + strings.Replace(fmt.Sprintf("%v", this.Extensions), "Extension", "Extension", 1) + `,`, `Extensions:` + repeatedStringForExtensions + `,`,
`Configs:` + strings.Replace(fmt.Sprintf("%v", this.Configs), "Config", "Config", 1) + `,`, `Configs:` + repeatedStringForConfigs + `,`,
`}`, `}`,
}, "") }, "")
return s return s
@ -692,8 +772,13 @@ func (this *ClusterSnapshot) String() string {
if this == nil { if this == nil {
return "nil" return "nil"
} }
repeatedStringForMembers := "[]*RaftMember{"
for _, f := range this.Members {
repeatedStringForMembers += strings.Replace(fmt.Sprintf("%v", f), "RaftMember", "RaftMember", 1) + ","
}
repeatedStringForMembers += "}"
s := strings.Join([]string{`&ClusterSnapshot{`, s := strings.Join([]string{`&ClusterSnapshot{`,
`Members:` + strings.Replace(fmt.Sprintf("%v", this.Members), "RaftMember", "RaftMember", 1) + `,`, `Members:` + repeatedStringForMembers + `,`,
`Removed:` + fmt.Sprintf("%v", this.Removed) + `,`, `Removed:` + fmt.Sprintf("%v", this.Removed) + `,`,
`}`, `}`,
}, "") }, "")
@ -1060,10 +1145,7 @@ func (m *StoreSnapshot) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthSnapshot
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthSnapshot return ErrInvalidLengthSnapshot
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1223,10 +1305,7 @@ func (m *ClusterSnapshot) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthSnapshot
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthSnapshot return ErrInvalidLengthSnapshot
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1361,10 +1440,7 @@ func (m *Snapshot) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthSnapshot
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthSnapshot return ErrInvalidLengthSnapshot
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1382,6 +1458,7 @@ func (m *Snapshot) Unmarshal(dAtA []byte) error {
func skipSnapshot(dAtA []byte) (n int, err error) { func skipSnapshot(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
depth := 0
for iNdEx < l { for iNdEx < l {
var wire uint64 var wire uint64
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -1413,10 +1490,8 @@ func skipSnapshot(dAtA []byte) (n int, err error) {
break break
} }
} }
return iNdEx, nil
case 1: case 1:
iNdEx += 8 iNdEx += 8
return iNdEx, nil
case 2: case 2:
var length int var length int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -1437,55 +1512,30 @@ func skipSnapshot(dAtA []byte) (n int, err error) {
return 0, ErrInvalidLengthSnapshot return 0, ErrInvalidLengthSnapshot
} }
iNdEx += length iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthSnapshot
}
return iNdEx, nil
case 3: case 3:
for { depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowSnapshot
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipSnapshot(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthSnapshot
}
}
return iNdEx, nil
case 4: case 4:
return iNdEx, nil if depth == 0 {
return 0, ErrUnexpectedEndOfGroupSnapshot
}
depth--
case 5: case 5:
iNdEx += 4 iNdEx += 4
return iNdEx, nil
default: default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType) return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
} }
if iNdEx < 0 {
return 0, ErrInvalidLengthSnapshot
}
if depth == 0 {
return iNdEx, nil
}
} }
panic("unreachable") return 0, io.ErrUnexpectedEOF
} }
var ( var (
ErrInvalidLengthSnapshot = fmt.Errorf("proto: negative length found during unmarshaling") ErrInvalidLengthSnapshot = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowSnapshot = fmt.Errorf("proto: integer overflow") ErrIntOverflowSnapshot = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupSnapshot = fmt.Errorf("proto: unexpected end of group")
) )

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

File diff suppressed because it is too large Load Diff

View File

@ -11,6 +11,7 @@ import (
descriptor "github.com/gogo/protobuf/protoc-gen-gogo/descriptor" descriptor "github.com/gogo/protobuf/protoc-gen-gogo/descriptor"
io "io" io "io"
math "math" math "math"
math_bits "math/bits"
reflect "reflect" reflect "reflect"
strings "strings" strings "strings"
) )
@ -24,7 +25,7 @@ var _ = math.Inf
// is compatible with the proto package it is being compiled against. // is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the // A compilation error at this line likely means your copy of the
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type WatchSelectors struct { type WatchSelectors struct {
// supported by all object types // supported by all object types
@ -59,7 +60,7 @@ func (m *WatchSelectors) XXX_Marshal(b []byte, deterministic bool) ([]byte, erro
return xxx_messageInfo_WatchSelectors.Marshal(b, m, deterministic) return xxx_messageInfo_WatchSelectors.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -95,7 +96,7 @@ func (m *StoreObject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
return xxx_messageInfo_StoreObject.Marshal(b, m, deterministic) return xxx_messageInfo_StoreObject.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -136,7 +137,7 @@ func (m *TLSAuthorization) XXX_Marshal(b []byte, deterministic bool) ([]byte, er
return xxx_messageInfo_TLSAuthorization.Marshal(b, m, deterministic) return xxx_messageInfo_TLSAuthorization.Marshal(b, m, deterministic)
} else { } else {
b = b[:cap(b)] b = b[:cap(b)]
n, err := m.MarshalTo(b) n, err := m.MarshalToSizedBuffer(b)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -293,7 +294,7 @@ func (m *TLSAuthorization) CopyFrom(src interface{}) {
func (m *WatchSelectors) Marshal() (dAtA []byte, err error) { func (m *WatchSelectors) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -301,147 +302,152 @@ func (m *WatchSelectors) Marshal() (dAtA []byte, err error) {
} }
func (m *WatchSelectors) MarshalTo(dAtA []byte) (int, error) { func (m *WatchSelectors) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *WatchSelectors) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.ID != nil {
dAtA[i] = 0x8
i++
if *m.ID {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.IDPrefix != nil {
dAtA[i] = 0x10
i++
if *m.IDPrefix {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Name != nil {
dAtA[i] = 0x18
i++
if *m.Name {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.NamePrefix != nil {
dAtA[i] = 0x20
i++
if *m.NamePrefix {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Custom != nil {
dAtA[i] = 0x28
i++
if *m.Custom {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.CustomPrefix != nil {
dAtA[i] = 0x30
i++
if *m.CustomPrefix {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.ServiceID != nil {
dAtA[i] = 0x38
i++
if *m.ServiceID {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.NodeID != nil {
dAtA[i] = 0x40
i++
if *m.NodeID {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Slot != nil {
dAtA[i] = 0x48
i++
if *m.Slot {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.DesiredState != nil {
dAtA[i] = 0x50
i++
if *m.DesiredState {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Role != nil {
dAtA[i] = 0x58
i++
if *m.Role {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Membership != nil {
dAtA[i] = 0x60
i++
if *m.Membership {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Kind != nil { if m.Kind != nil {
dAtA[i] = 0x68 i--
i++
if *m.Kind { if *m.Kind {
dAtA[i] = 1 dAtA[i] = 1
} else { } else {
dAtA[i] = 0 dAtA[i] = 0
} }
i++ i--
dAtA[i] = 0x68
} }
return i, nil if m.Membership != nil {
i--
if *m.Membership {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x60
}
if m.Role != nil {
i--
if *m.Role {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x58
}
if m.DesiredState != nil {
i--
if *m.DesiredState {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x50
}
if m.Slot != nil {
i--
if *m.Slot {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x48
}
if m.NodeID != nil {
i--
if *m.NodeID {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x40
}
if m.ServiceID != nil {
i--
if *m.ServiceID {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x38
}
if m.CustomPrefix != nil {
i--
if *m.CustomPrefix {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x30
}
if m.Custom != nil {
i--
if *m.Custom {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x28
}
if m.NamePrefix != nil {
i--
if *m.NamePrefix {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x20
}
if m.Name != nil {
i--
if *m.Name {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x18
}
if m.IDPrefix != nil {
i--
if *m.IDPrefix {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x10
}
if m.ID != nil {
i--
if *m.ID {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
} }
func (m *StoreObject) Marshal() (dAtA []byte, err error) { func (m *StoreObject) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -449,29 +455,36 @@ func (m *StoreObject) Marshal() (dAtA []byte, err error) {
} }
func (m *StoreObject) MarshalTo(dAtA []byte) (int, error) { func (m *StoreObject) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *StoreObject) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if m.WatchSelectors == nil { if m.WatchSelectors == nil {
return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("watch_selectors") return 0, github_com_gogo_protobuf_proto.NewRequiredNotSetError("watch_selectors")
} else { } else {
dAtA[i] = 0xa {
i++ size, err := m.WatchSelectors.MarshalToSizedBuffer(dAtA[:i])
i = encodeVarintPlugin(dAtA, i, uint64(m.WatchSelectors.Size())) if err != nil {
n1, err := m.WatchSelectors.MarshalTo(dAtA[i:]) return 0, err
if err != nil { }
return 0, err i -= size
i = encodeVarintPlugin(dAtA, i, uint64(size))
} }
i += n1 i--
dAtA[i] = 0xa
} }
return i, nil return len(dAtA) - i, nil
} }
func (m *TLSAuthorization) Marshal() (dAtA []byte, err error) { func (m *TLSAuthorization) Marshal() (dAtA []byte, err error) {
size := m.Size() size := m.Size()
dAtA = make([]byte, size) dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA) n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil { if err != nil {
return nil, err return nil, err
} }
@ -479,46 +492,47 @@ func (m *TLSAuthorization) Marshal() (dAtA []byte, err error) {
} }
func (m *TLSAuthorization) MarshalTo(dAtA []byte) (int, error) { func (m *TLSAuthorization) MarshalTo(dAtA []byte) (int, error) {
var i int size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *TLSAuthorization) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i _ = i
var l int var l int
_ = l _ = l
if len(m.Roles) > 0 {
for _, s := range m.Roles {
dAtA[i] = 0xa
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if m.Insecure != nil { if m.Insecure != nil {
dAtA[i] = 0x10 i--
i++
if *m.Insecure { if *m.Insecure {
dAtA[i] = 1 dAtA[i] = 1
} else { } else {
dAtA[i] = 0 dAtA[i] = 0
} }
i++ i--
dAtA[i] = 0x10
} }
return i, nil if len(m.Roles) > 0 {
for iNdEx := len(m.Roles) - 1; iNdEx >= 0; iNdEx-- {
i -= len(m.Roles[iNdEx])
copy(dAtA[i:], m.Roles[iNdEx])
i = encodeVarintPlugin(dAtA, i, uint64(len(m.Roles[iNdEx])))
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
} }
func encodeVarintPlugin(dAtA []byte, offset int, v uint64) int { func encodeVarintPlugin(dAtA []byte, offset int, v uint64) int {
offset -= sovPlugin(v)
base := offset
for v >= 1<<7 { for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80) dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7 v >>= 7
offset++ offset++
} }
dAtA[offset] = uint8(v) dAtA[offset] = uint8(v)
return offset + 1 return base
} }
func (m *WatchSelectors) Size() (n int) { func (m *WatchSelectors) Size() (n int) {
if m == nil { if m == nil {
@ -600,14 +614,7 @@ func (m *TLSAuthorization) Size() (n int) {
} }
func sovPlugin(x uint64) (n int) { func sovPlugin(x uint64) (n int) {
for { return (math_bits.Len64(x|1) + 6) / 7
n++
x >>= 7
if x == 0 {
break
}
}
return n
} }
func sozPlugin(x uint64) (n int) { func sozPlugin(x uint64) (n int) {
return sovPlugin(uint64((x << 1) ^ uint64((int64(x) >> 63)))) return sovPlugin(uint64((x << 1) ^ uint64((int64(x) >> 63))))
@ -639,7 +646,7 @@ func (this *StoreObject) String() string {
return "nil" return "nil"
} }
s := strings.Join([]string{`&StoreObject{`, s := strings.Join([]string{`&StoreObject{`,
`WatchSelectors:` + strings.Replace(fmt.Sprintf("%v", this.WatchSelectors), "WatchSelectors", "WatchSelectors", 1) + `,`, `WatchSelectors:` + strings.Replace(this.WatchSelectors.String(), "WatchSelectors", "WatchSelectors", 1) + `,`,
`}`, `}`,
}, "") }, "")
return s return s
@ -971,10 +978,7 @@ func (m *WatchSelectors) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthPlugin
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthPlugin return ErrInvalidLengthPlugin
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1062,10 +1066,7 @@ func (m *StoreObject) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthPlugin
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthPlugin return ErrInvalidLengthPlugin
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1171,10 +1172,7 @@ func (m *TLSAuthorization) Unmarshal(dAtA []byte) error {
if err != nil { if err != nil {
return err return err
} }
if skippy < 0 { if (skippy < 0) || (iNdEx+skippy) < 0 {
return ErrInvalidLengthPlugin
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthPlugin return ErrInvalidLengthPlugin
} }
if (iNdEx + skippy) > l { if (iNdEx + skippy) > l {
@ -1192,6 +1190,7 @@ func (m *TLSAuthorization) Unmarshal(dAtA []byte) error {
func skipPlugin(dAtA []byte) (n int, err error) { func skipPlugin(dAtA []byte) (n int, err error) {
l := len(dAtA) l := len(dAtA)
iNdEx := 0 iNdEx := 0
depth := 0
for iNdEx < l { for iNdEx < l {
var wire uint64 var wire uint64
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -1223,10 +1222,8 @@ func skipPlugin(dAtA []byte) (n int, err error) {
break break
} }
} }
return iNdEx, nil
case 1: case 1:
iNdEx += 8 iNdEx += 8
return iNdEx, nil
case 2: case 2:
var length int var length int
for shift := uint(0); ; shift += 7 { for shift := uint(0); ; shift += 7 {
@ -1247,55 +1244,30 @@ func skipPlugin(dAtA []byte) (n int, err error) {
return 0, ErrInvalidLengthPlugin return 0, ErrInvalidLengthPlugin
} }
iNdEx += length iNdEx += length
if iNdEx < 0 {
return 0, ErrInvalidLengthPlugin
}
return iNdEx, nil
case 3: case 3:
for { depth++
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowPlugin
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipPlugin(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
if iNdEx < 0 {
return 0, ErrInvalidLengthPlugin
}
}
return iNdEx, nil
case 4: case 4:
return iNdEx, nil if depth == 0 {
return 0, ErrUnexpectedEndOfGroupPlugin
}
depth--
case 5: case 5:
iNdEx += 4 iNdEx += 4
return iNdEx, nil
default: default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType) return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
} }
if iNdEx < 0 {
return 0, ErrInvalidLengthPlugin
}
if depth == 0 {
return iNdEx, nil
}
} }
panic("unreachable") return 0, io.ErrUnexpectedEOF
} }
var ( var (
ErrInvalidLengthPlugin = fmt.Errorf("proto: negative length found during unmarshaling") ErrInvalidLengthPlugin = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowPlugin = fmt.Errorf("proto: integer overflow") ErrIntOverflowPlugin = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupPlugin = fmt.Errorf("proto: unexpected end of group")
) )

View File

@ -8,69 +8,72 @@
# In >=1.11, those errors were brought back but the string had changed again. # In >=1.11, those errors were brought back but the string had changed again.
# After updating GRPC, if integration test failures occur, verify that the # After updating GRPC, if integration test failures occur, verify that the
# string matching there is correct. # string matching there is correct.
google.golang.org/grpc 25c4f928eaa6d96443009bd842389fb4fa48664e # v1.20.1 google.golang.org/grpc f495f5b15ae7ccda3b38c53a1bfcde4c1a58a2bc # v1.27.1
github.com/gogo/protobuf ba06b47c162d49f2af050fb4c75bcbc86a159d5c # v1.2.1 github.com/gogo/protobuf b03c65ea87cdc3521ede29f62fe3ce239267c1bc # v1.3.2
github.com/golang/protobuf aa810b61a9c79d51363740d207bb46cf8e620ed5 # v1.2.0 github.com/golang/protobuf 84668698ea25b64748563aa20726db66a6b8d299 # v1.3.5
github.com/matttproud/golang_protobuf_extensions c12348ce28de40eed0136aa2b644d0ee0650e56c # v1.0.1 github.com/matttproud/golang_protobuf_extensions c12348ce28de40eed0136aa2b644d0ee0650e56c # v1.0.1
google.golang.org/genproto 694d95ba50e67b2e363f3483057db5d4910c18f9 google.golang.org/genproto 3f1135a288c9a07e340ae8ba4cc6c7065a3160e8
# metrics # metrics
github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0 github.com/grpc-ecosystem/go-grpc-prometheus c225b8c3b01faf2899099b768856a9e916e5087b # v1.2.0
github.com/docker/go-metrics d466d4f6fd960e01820085bd7e1a24426ee7ef18 github.com/docker/go-metrics b619b3592b65de4f087d9f16863a7e6ff905973c # v0.0.1
# etcd/raft # etcd/raft
github.com/coreos/etcd d57e8b8d97adfc4a6c224fe116714bf1a1f3beb9 # v3.3.12 github.com/coreos/etcd 2c834459e1aab78a5d5219c7dfe42335fc4b617a # v3.3.25
github.com/coreos/go-systemd v17
github.com/coreos/pkg v3
github.com/prometheus/client_golang v0.8.0
github.com/prometheus/client_model 6f3806018612930941127f2a7c6c453ba2c527d2
github.com/prometheus/common 7600349dcfe1abd18d72d3a1770870d9800a7801
github.com/prometheus/procfs 7d6f385de8bea29190f15ba9931442a0eaef9af7
github.com/docker/distribution 0d3efadf0154c2b8a4e7b6621fff9809655cc580 # go-systemd v17 is required by github.com/coreos/pkg/capnslog/journald_formatter.go
github.com/docker/docker 827cb09f87964ed38b46502f22a585f2ed4a78e1 github.com/coreos/go-systemd 39ca1b05acc7ad1220e09f133283b8859a8b71ab # v17
github.com/docker/go-connections 7395e3f8aa162843a74ed6d48e79627d9792ac55 # v0.4.0 github.com/coreos/pkg 97fdf19511ea361ae1c100dd393cc47f8dcfa1e1 # v4
github.com/docker/go-events 9461782956ad83b30282bf90e31fa6a70c255ba9 github.com/prometheus/client_golang 6edbbd9e560190e318cdc5b4d3e630b442858380 # v1.6.0
github.com/docker/go-units 519db1ee28dcc9fd2474ae59fca29a810482bfb1 # v0.4.0 github.com/prometheus/client_model 7bc5445566f0fe75b15de23e6b93886e982d7bf9 # v0.2.0
github.com/docker/libkv 458977154600b9f23984d9f4b82e79570b5ae12b github.com/prometheus/common d978bcb1309602d68bb4ba69cf3f8ed900e07308 # v0.9.1
github.com/docker/libnetwork 09cdcc8c0eab3946c2d70e8f6225b05baf1e90d1 github.com/prometheus/procfs 46159f73e74d1cb8dc223deef9b2d049286f46b1 # v0.0.11
github.com/opencontainers/runc 425e105d5a03fabd737a126ad93d62a9eeede87f # v1.0.0-rc8 github.com/cespare/xxhash/v2 d7df74196a9e781ede915320c11c378c1b2f3a1f # v2.1.1
github.com/opencontainers/go-digest v1.0.0-rc1
github.com/opencontainers/image-spec v1.0.1
github.com/ishidawataru/sctp 6e2cb1366111dcf547c13531e3a263a067715847
github.com/davecgh/go-spew 8991bc29aa16c548c550c7ff78260e27b9ab7c73 # v1.1.1 github.com/docker/distribution 0d3efadf0154c2b8a4e7b6621fff9809655cc580
github.com/Microsoft/go-winio 6c72808b55902eae4c5943626030429ff20f3b63 # v0.4.14 github.com/docker/docker 0ad2293d0e5bbf4c966a0e8b27c3ac3835265577 # master / v21.xx-dev
github.com/sirupsen/logrus 8bdbc7bcc01dcbb8ec23dc8a28e332258d25251f # v1.4.1 github.com/docker/go-connections 7395e3f8aa162843a74ed6d48e79627d9792ac55 # v0.4.0
github.com/beorn7/perks 37c8de3658fcb183f997c4e13e8337516ab753e6 # v1.0.1 github.com/docker/go-events e31b211e4f1cd09aa76fe4ac244571fab96ae47f
github.com/cloudflare/cfssl 1.3.2 github.com/docker/go-units 519db1ee28dcc9fd2474ae59fca29a810482bfb1 # v0.4.0
github.com/dustin/go-humanize 9f541cc9db5d55bce703bd99987c9d5cb8eea45e # v1.0.0 github.com/docker/libkv 458977154600b9f23984d9f4b82e79570b5ae12b
github.com/fernet/fernet-go 9eac43b88a5efb8651d24de9b68e87567e029736 github.com/opencontainers/runc b9ee9c6314599f1b4a7f497e1f1f856fe433d3b7 # v1.0.0-rc95
github.com/google/certificate-transparency-go v1.0.20 github.com/opencontainers/go-digest ea51bea511f75cfa3ef6098cc253c5c3609b037a # v1.0.0
github.com/hashicorp/go-immutable-radix 826af9ccf0feeee615d546d69b11f8e98da8c8f1 git://github.com/tonistiigi/go-immutable-radix.git github.com/opencontainers/image-spec d60099175f88c47cd379c4738d158884749ed235 # v1.0.1
github.com/hashicorp/go-memdb cb9a474f84cc5e41b273b20c6927680b2a8776ad github.com/ishidawataru/sctp f2269e66cdee387bd321445d5d300893449805be
github.com/hashicorp/golang-lru 7087cb70de9f7a8bc0a10c375cb0d2280a8edf9c # v0.5.1 github.com/containerd/containerd 36cc874494a56a253cd181a1a685b44b58a2e34a # v1.5.2
github.com/inconshreveable/mousetrap 76626ae9c91c4f2a10f34cad8ce83ea42c93bb75
github.com/phayes/permbits f7e3ac5e859d0b919c5068d581cc4c5d4f4f9bc5 github.com/davecgh/go-spew 8991bc29aa16c548c550c7ff78260e27b9ab7c73 # v1.1.1
code.cloudfoundry.org/clock 02e53af36e6c978af692887ed449b74026d76fec github.com/Microsoft/go-winio 5b44b70ab3ab4d291a7c1d28afe7b4afeced0ed4 # v0.4.15
github.com/pkg/errors ba968bfe8b2f7e042a574c888954fccecfa385b4 # v0.8.1 github.com/sirupsen/logrus 6699a89a232f3db797f2e280639854bbc4b89725 # v1.7.0
github.com/pmezard/go-difflib 792786c7400a136282c1664665ae0a8db921c6c2 # v1.0.0 github.com/beorn7/perks 37c8de3658fcb183f997c4e13e8337516ab753e6 # v1.0.1
github.com/rcrowley/go-metrics 51425a2415d21afadfd55cd93432c0bc69e9598d github.com/cloudflare/cfssl 5d63dbd981b5c408effbb58c442d54761ff94fbd # 1.3.2
github.com/spf13/cobra 8e91712f174ced10270cf66615e0a9127e7c4de5 github.com/dustin/go-humanize 9f541cc9db5d55bce703bd99987c9d5cb8eea45e # v1.0.0
github.com/spf13/pflag 7f60f83a2c81bc3c3c0d5297f61ddfa68da9d3b7 github.com/fernet/fernet-go 9eac43b88a5efb8651d24de9b68e87567e029736
github.com/stretchr/testify ffdc059bfe9ce6a4e144ba849dbedead332c6053 # v1.3.0 github.com/google/certificate-transparency-go 37a384cd035e722ea46e55029093e26687138edf # v1.0.20
go.etcd.io/bbolt a0458a2b35708eef59eb5f620ceb3cd1c01a824d # v1.3.3 github.com/hashicorp/go-immutable-radix 826af9ccf0feeee615d546d69b11f8e98da8c8f1 git://github.com/tonistiigi/go-immutable-radix.git
golang.org/x/crypto 88737f569e3a9c7ab309cdc09a07fe7fc87233c3 github.com/hashicorp/go-memdb cb9a474f84cc5e41b273b20c6927680b2a8776ad
golang.org/x/net f3200d17e092c607f615320ecaad13d87ad9a2b3 github.com/hashicorp/golang-lru 7f827b33c0f158ec5dfbba01bb0b14a4541fd81d # v0.5.3
golang.org/x/sys 9eafafc0a87e0fd0aeeba439a4573537970c44c7 github.com/inconshreveable/mousetrap 76626ae9c91c4f2a10f34cad8ce83ea42c93bb75 # v1.0.0
golang.org/x/text f21a4dfb5e38f5895301dc265a8def02365cc3d0 # v0.3.0 github.com/phayes/permbits f7e3ac5e859d0b919c5068d581cc4c5d4f4f9bc5
golang.org/x/time fbb02b2291d28baffd63558aa44b4b56f178d650 code.cloudfoundry.org/clock 02e53af36e6c978af692887ed449b74026d76fec # v1.0.0
github.com/pkg/errors 614d223910a179a466c1767a985424175c39b465 # v0.9.1
github.com/pmezard/go-difflib 792786c7400a136282c1664665ae0a8db921c6c2 # v1.0.0
github.com/rcrowley/go-metrics 51425a2415d21afadfd55cd93432c0bc69e9598d
github.com/spf13/cobra 8380ddd3132bdf8fd77731725b550c181dda0aa8 # v1.1.3
github.com/spf13/pflag 2e9d26c8c37aae03e3f9d4e90b7116f5accb7cab # v1.0.5
github.com/stretchr/testify ffdc059bfe9ce6a4e144ba849dbedead332c6053 # v1.3.0
go.etcd.io/bbolt 232d8fc87f50244f9c808f4745759e08a304c029 # v1.3.5
golang.org/x/crypto c1f2f97bffc9c53fc40a1a28a5b460094c0050d9
golang.org/x/net 6772e930b67bb09bf22262c7378e7d2f67cf59d1
golang.org/x/sys d19ff857e887eacb631721f188c7d365c2331456
golang.org/x/text 23ae387dee1f90d29a23c0e87ee0b46038fbed0e # v0.3.3
golang.org/x/time 555d28b269f0569763d25dbe1a237ae74c6bcc82
# ginkgo is used for testing in some places in the code. this is it and its # ginkgo is used for testing in some places in the code. this is it and its
# sub-dependencies. # sub-dependencies.
github.com/onsi/ginkgo v1.8.0 github.com/onsi/ginkgo eea6ad008b96acdaa524f5b409513bf062b500ad # v1.8.0
github.com/onsi/gomega v1.5.0 github.com/onsi/gomega 90e289841c1ed79b7a598a7cd9959750cb5e89e2 # v1.5.0
gopkg.in/yaml.v2 v2.2.1 gopkg.in/yaml.v2 7649d4548cb53a614db133b2a8ac1f31859dda8c # v2.4.0
github.com/hpcloud/tail v1.0.0 github.com/hpcloud/tail a30252cb686a21eb2d0b98132633053ec2f7f1e5 # v1.0.0
gopkg.in/fsnotify.v1 v1.4.7 gopkg.in/fsnotify.v1 c2828203cd70a50dcccfb2761f8b1f8ceef9a8e9 # v1.4.7
gopkg.in/tomb.v1 v1 gopkg.in/tomb.v1 dd632973f1e7218eb1089048e0798ec9ae7dceb8 # v1