809344a6f5
- Add endpoints related to peering: read, list, generate token, initiate peering
- Update node/service/check table indexing to account for peers
- Foundational changes for pushing service updates to a peer
- Plumb peer name through Health.ServiceNodes path
see: ENT-1765, ENT-1280, ENT-1283, ENT-1283, ENT-1756, ENT-1739, ENT-1750, ENT-1679,
ENT-1709, ENT-1704, ENT-1690, ENT-1689, ENT-1702, ENT-1701, ENT-1683, ENT-1663,
ENT-1650, ENT-1678, ENT-1628, ENT-1658, ENT-1640, ENT-1637, ENT-1597, ENT-1634,
ENT-1613, ENT-1616, ENT-1617, ENT-1591, ENT-1588, ENT-1596, ENT-1572, ENT-1555
Co-authored-by: R.B. Boyer <rb@hashicorp.com>
Co-authored-by: freddygv <freddy@hashicorp.com>
Co-authored-by: Chris S. Kim <ckim@hashicorp.com>
Co-authored-by: Evan Culver <eculver@hashicorp.com>
Co-authored-by: Nitya Dhanushkodi <nitya@hashicorp.com>
91 lines
2.3 KiB
Go
91 lines
2.3 KiB
Go
// Code generated by mog. DO NOT EDIT.
|
|
|
|
package pbservice
|
|
|
|
import "github.com/hashicorp/consul/agent/structs"
|
|
|
|
func NodeToStructs(s *Node, t *structs.Node) {
|
|
if s == nil {
|
|
return
|
|
}
|
|
t.ID = NodeIDType(s.ID)
|
|
t.Node = s.Node
|
|
t.Address = s.Address
|
|
t.Datacenter = s.Datacenter
|
|
t.Partition = s.Partition
|
|
t.PeerName = s.PeerName
|
|
t.TaggedAddresses = s.TaggedAddresses
|
|
t.Meta = s.Meta
|
|
t.RaftIndex = RaftIndexToStructs(s.RaftIndex)
|
|
}
|
|
func NodeFromStructs(t *structs.Node, s *Node) {
|
|
if s == nil {
|
|
return
|
|
}
|
|
s.ID = string(t.ID)
|
|
s.Node = t.Node
|
|
s.Address = t.Address
|
|
s.Datacenter = t.Datacenter
|
|
s.Partition = t.Partition
|
|
s.PeerName = t.PeerName
|
|
s.TaggedAddresses = t.TaggedAddresses
|
|
s.Meta = t.Meta
|
|
s.RaftIndex = NewRaftIndexFromStructs(t.RaftIndex)
|
|
}
|
|
func NodeServiceToStructs(s *NodeService, t *structs.NodeService) {
|
|
if s == nil {
|
|
return
|
|
}
|
|
t.Kind = structs.ServiceKind(s.Kind)
|
|
t.ID = s.ID
|
|
t.Service = s.Service
|
|
t.Tags = s.Tags
|
|
t.Address = s.Address
|
|
t.TaggedAddresses = MapStringServiceAddressToStructs(s.TaggedAddresses)
|
|
t.Meta = s.Meta
|
|
t.Port = int(s.Port)
|
|
t.SocketPath = s.SocketPath
|
|
t.Weights = WeightsPtrToStructs(s.Weights)
|
|
t.EnableTagOverride = s.EnableTagOverride
|
|
if s.Proxy != nil {
|
|
ConnectProxyConfigToStructs(s.Proxy, &t.Proxy)
|
|
}
|
|
if s.Connect != nil {
|
|
ServiceConnectToStructs(s.Connect, &t.Connect)
|
|
}
|
|
t.LocallyRegisteredAsSidecar = s.LocallyRegisteredAsSidecar
|
|
t.EnterpriseMeta = EnterpriseMetaToStructs(s.EnterpriseMeta)
|
|
t.PeerName = s.PeerName
|
|
t.RaftIndex = RaftIndexToStructs(s.RaftIndex)
|
|
}
|
|
func NodeServiceFromStructs(t *structs.NodeService, s *NodeService) {
|
|
if s == nil {
|
|
return
|
|
}
|
|
s.Kind = string(t.Kind)
|
|
s.ID = t.ID
|
|
s.Service = t.Service
|
|
s.Tags = t.Tags
|
|
s.Address = t.Address
|
|
s.TaggedAddresses = NewMapStringServiceAddressFromStructs(t.TaggedAddresses)
|
|
s.Meta = t.Meta
|
|
s.Port = int32(t.Port)
|
|
s.SocketPath = t.SocketPath
|
|
s.Weights = NewWeightsPtrFromStructs(t.Weights)
|
|
s.EnableTagOverride = t.EnableTagOverride
|
|
{
|
|
var x ConnectProxyConfig
|
|
ConnectProxyConfigFromStructs(&t.Proxy, &x)
|
|
s.Proxy = &x
|
|
}
|
|
{
|
|
var x ServiceConnect
|
|
ServiceConnectFromStructs(&t.Connect, &x)
|
|
s.Connect = &x
|
|
}
|
|
s.LocallyRegisteredAsSidecar = t.LocallyRegisteredAsSidecar
|
|
s.EnterpriseMeta = NewEnterpriseMetaFromStructs(t.EnterpriseMeta)
|
|
s.PeerName = t.PeerName
|
|
s.RaftIndex = NewRaftIndexFromStructs(t.RaftIndex)
|
|
}
|