const NodeTable = "NodeTable"

var (
    ErrInvalidLengthNetworkdb = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowNetworkdb   = fmt.Errorf("proto: integer overflow")
)

var MessageType_name = map[int32]string{
    0:  "INVALID",
    1:  "NETWORK_EVENT",
    2:  "TABLE_EVENT",
    3:  "PUSH_PULL",
    4:  "BULK_SYNC",
    5:  "COMPOUND",
    6:  "NODE_EVENT",
}

var MessageType_value = map[string]int32{
    "INVALID":       0,
    "NETWORK_EVENT": 1,
    "TABLE_EVENT":   2,
    "PUSH_PULL":     3,
    "BULK_SYNC":     4,
    "COMPOUND":      5,
    "NODE_EVENT":    6,
}

var NetDbPaths2Func = map[string]diagnostic.HTTPHandlerFunc{
    "/join":         dbJoin,
    "/networkpeers": dbPeers,
    "/clusterpeers": dbClusterPeers,
    "/joinnetwork":  dbJoinNetwork,
    "/leavenetwork": dbLeaveNetwork,
    "/createentry":  dbCreateEntry,
    "/updateentry":  dbUpdateEntry,
    "/deleteentry":  dbDeleteEntry,
    "/getentry":     dbGetEntry,
    "/gettable":     dbGetTable,
    "/networkstats": dbNetworkStats,
}

var NetworkEvent_Type_name = map[int32]string{
    0:  "INVALID",
    1:  "JOIN",
    2:  "LEAVE",
}

var NetworkEvent_Type_value = map[string]int32{
    "INVALID": 0,
    "JOIN":    1,
    "LEAVE":   2,
}

var NodeEvent_Type_name = map[int32]string{
    0:  "INVALID",
    1:  "JOIN",
    2:  "LEAVE",
}

var NodeEvent_Type_value = map[string]int32{
    "INVALID": 0,
    "JOIN":    1,
    "LEAVE":   2,
}

var TableEvent_Type_name = map[int32]string{
    0:  "INVALID",
    1:  "CREATE",
    2:  "UPDATE",
    3:  "DELETE",
}

var TableEvent_Type_value = map[string]int32{
    "INVALID": 0,
    "CREATE":  1,
    "UPDATE":  2,
    "DELETE":  3,
}

type BulkSyncMessage struct {
    // Lamport time when this bulk sync was initiated.
    LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,1,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
    // Indicates if this bulksync is a response to a bulk sync
    // request from a peer node.
    Unsolicited bool `protobuf:"varint,2,opt,name=unsolicited,proto3" json:"unsolicited,omitempty"`
    // Name of the node which is producing this bulk sync message.
    NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
    // List of network names whose table entries are getting
    // bulksynced as part of the bulksync.
    Networks []string `protobuf:"bytes,4,rep,name=networks" json:"networks,omitempty"`
    // Bulksync payload
    Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
}

type CompoundMessage struct {
    // A list of simple messages.
    Messages []*CompoundMessage_SimpleMessage `protobuf:"bytes,1,rep,name=messages" json:"messages,omitempty"`
}

type CompoundMessage_SimpleMessage struct {
    // Bytestring payload of a message constructed using
    // other message type definitions.
    Payload []byte `protobuf:"bytes,1,opt,name=Payload,proto3" json:"Payload,omitempty"`
}

type Config struct {
    // NodeID is the node unique identifier of the node when is part of the cluster
    NodeID string

    // Hostname is the node hostname.
    Hostname string

    // BindAddr is the IP on which networkdb listens. It can be
    // 0.0.0.0 to listen on all addresses on the host.
    BindAddr string

    // AdvertiseAddr is the node's IP address that we advertise for
    // cluster communication.
    AdvertiseAddr string

    // BindPort is the local node's port to which we bind to for
    // cluster communication.
    BindPort int

    // Keys to be added to the Keyring of the memberlist. Key at index
    // 0 is the primary key
    Keys [][]byte

    // PacketBufferSize is the maximum number of bytes that memberlist will
    // put in a packet (this will be for UDP packets by default with a NetTransport).
    // A safe value for this is typically 1400 bytes (which is the default). However,
    // depending on your network's MTU (Maximum Transmission Unit) you may
    // be able to increase this to get more content into each gossip packet.
    PacketBufferSize int

    // StatsPrintPeriod the period to use to print queue stats
    // Default is 5min
    StatsPrintPeriod time.Duration

    // HealthPrintPeriod the period to use to print the health score
    // Default is 1min
    HealthPrintPeriod time.Duration
    // contains filtered or unexported fields
}

type CreateEvent event

type DeleteEvent event

type GossipMessage struct {
    Type MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.MessageType" json:"type,omitempty"`
    Data []byte      `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

type MessageType int32

const (
    MessageTypeInvalid MessageType = 0
    // NetworkEvent message type is used to communicate network
    // attachments on the node.
    MessageTypeNetworkEvent MessageType = 1
    // TableEvent message type is used to communicate any table
    // CRUD event that happened on the node.
    MessageTypeTableEvent MessageType = 2
    // PushPull message type is used to syncup all network
    // attachments on a peer node either during startup of this
    // node or with a random peer node periodically thereafter.
    MessageTypePushPull MessageType = 3
    // BulkSync message is used to bulksync the whole networkdb
    // state with a peer node during startup of this node or with
    // a random peer node periodically thereafter.
    MessageTypeBulkSync MessageType = 4
    // Compound message type is used to form a compound message
    // which is a pack of many message of above types, packed into
    // a single compound message.
    MessageTypeCompound MessageType = 5
    // NodeEvent message type is used to communicate node
    // join/leave events in the cluster
    MessageTypeNodeEvent MessageType = 6
)

type NetworkDB struct {
    sync.RWMutex
    // contains filtered or unexported fields
}

type NetworkEntry struct {
    // ID of the network
    NetworkID string `protobuf:"bytes,1,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
    // Latest lamport time of the network attachment when this
    // network event was recorded.
    LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
    // Source node name where this network attachment happened.
    NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
    // Indicates if a leave from this network is in progress.
    Leaving bool `protobuf:"varint,4,opt,name=leaving,proto3" json:"leaving,omitempty"`
}

type NetworkEvent struct {
    Type NetworkEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.NetworkEvent_Type" json:"type,omitempty"`
    // Lamport time using a network lamport clock indicating the
    // time this event was generated on the node where it was
    // generated.
    LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
    // Source node name.
    NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
    // ID of the network for which the event is generated.
    NetworkID string `protobuf:"bytes,4,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
}

type NetworkEvent_Type int32

const (
    NetworkEventTypeInvalid NetworkEvent_Type = 0
    // Join event is generated when this node joins a network.
    NetworkEventTypeJoin NetworkEvent_Type = 1
    // Leave event is generated when this node leaves a network.
    NetworkEventTypeLeave NetworkEvent_Type = 2
)

type NetworkPushPull struct {
    // Lamport time when this push pull was initiated.
    LTime    github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,1,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
    Networks []*NetworkEntry                            `protobuf:"bytes,2,rep,name=networks" json:"networks,omitempty"`
    // Name of the node sending this push pull payload.
    NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
}

type NodeAddr struct {
    Addr net.IP
}

type NodeEvent struct {
    Type NodeEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.NodeEvent_Type" json:"type,omitempty"`
    // Lamport time using a network lamport clock indicating the
    // time this event was generated on the node where it was
    // generated.
    LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
    // Source node name.
    NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
}

type NodeEvent_Type int32

const (
    NodeEventTypeInvalid NodeEvent_Type = 0
    // Join event is generated when this node joins the cluster.
    NodeEventTypeJoin NodeEvent_Type = 1
    // Leave event is generated when this node leaves the cluster.
    NodeEventTypeLeave NodeEvent_Type = 2
)

type PeerClusterInfo struct {
    PeerInfo
}

type PeerInfo struct {
    Name string
    IP   string
}

type TableElem struct {
    Value []byte
    // contains filtered or unexported fields
}

type TableEvent struct {
    Type TableEvent_Type `protobuf:"varint,1,opt,name=type,proto3,enum=networkdb.TableEvent_Type" json:"type,omitempty"`
    // Lamport time when this event was generated.
    LTime github_com_hashicorp_serf_serf.LamportTime `protobuf:"varint,2,opt,name=l_time,json=lTime,proto3,customtype=github.com/hashicorp/serf/serf.LamportTime" json:"l_time"`
    // Node name where this event originated.
    NodeName string `protobuf:"bytes,3,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
    // ID of the network to which this table entry belongs.
    NetworkID string `protobuf:"bytes,4,opt,name=network_id,json=networkId,proto3" json:"network_id,omitempty"`
    // Name of the table to which this table entry belongs.
    TableName string `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
    // Entry key.
    Key string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
    // Entry value.
    Value []byte `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
    // Residual reap time for the entry before getting deleted in seconds
    ResidualReapTime int32 `protobuf:"varint,8,opt,name=residual_reap_time,json=residualReapTime,proto3" json:"residual_reap_time,omitempty"`
}

type TableEvent_Type int32

const (
    TableEventTypeInvalid TableEvent_Type = 0
    // Create signifies that this table entry was just
    // created.
    TableEventTypeCreate TableEvent_Type = 1
    // Update signifies that this table entry was just
    // updated.
    TableEventTypeUpdate TableEvent_Type = 2
    // Delete signifies that this table entry was just
    // updated.
    TableEventTypeDelete TableEvent_Type = 3
)

type UpdateEvent event