ipstate

Documentation

Index

• func RegisterIpamStateInterrogatorServer(s *grpc.Server, srv IpamStateInterrogatorServer)
• type IpRangesState
  • func (*IpRangesState) Descriptor() ([]byte, []int)
  • func (m *IpRangesState) GetRange() []*ipreceiver.IpRange
  • func (*IpRangesState) ProtoMessage()
  • func (m *IpRangesState) Reset()
  • func (m *IpRangesState) String() string
  • func (m *IpRangesState) XXX_DiscardUnknown()
  • func (m *IpRangesState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *IpRangesState) XXX_Merge(src proto.Message)
  • func (m *IpRangesState) XXX_Size() int
  • func (m *IpRangesState) XXX_Unmarshal(b []byte) error
• type IpamStateInterrogatorClient
  • func NewIpamStateInterrogatorClient(cc *grpc.ClientConn) IpamStateInterrogatorClient
• type IpamStateInterrogatorServer
• type PrefixIdentifier
  • func (*PrefixIdentifier) Descriptor() ([]byte, []int)
  • func (m *PrefixIdentifier) GetAddrFamily() *ipprovider.IpFamily
  • func (m *PrefixIdentifier) GetIdentifier() *ipreceiver.RangeIdentifier
  • func (*PrefixIdentifier) ProtoMessage()
  • func (m *PrefixIdentifier) Reset()
  • func (m *PrefixIdentifier) String() string
  • func (m *PrefixIdentifier) XXX_DiscardUnknown()
  • func (m *PrefixIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PrefixIdentifier) XXX_Merge(src proto.Message)
  • func (m *PrefixIdentifier) XXX_Size() int
  • func (m *PrefixIdentifier) XXX_Unmarshal(b []byte) error
• type SubnetsState
  • func (*SubnetsState) Descriptor() ([]byte, []int)
  • func (m *SubnetsState) GetSubnet() []*ipprovider.Subnet
  • func (*SubnetsState) ProtoMessage()
  • func (m *SubnetsState) Reset()
  • func (m *SubnetsState) String() string
  • func (m *SubnetsState) XXX_DiscardUnknown()
  • func (m *SubnetsState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *SubnetsState) XXX_Merge(src proto.Message)
  • func (m *SubnetsState) XXX_Size() int
  • func (m *SubnetsState) XXX_Unmarshal(b []byte) error
• type UnimplementedIpamStateInterrogatorServer
  • func (*UnimplementedIpamStateInterrogatorServer) GetAllocatedRanges(ctx context.Context, req *PrefixIdentifier) (*IpRangesState, error)
  • func (*UnimplementedIpamStateInterrogatorServer) GetAllocatedSubnets(ctx context.Context, req *PrefixIdentifier) (*SubnetsState, error)

Functions

func RegisterIpamStateInterrogatorServer

func RegisterIpamStateInterrogatorServer(s *grpc.Server, srv IpamStateInterrogatorServer)

Types

type IpRangesState

type IpRangesState struct {
	Range                []*ipreceiver.IpRange `protobuf:"bytes,1,rep,name=range,proto3" json:"range,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*IpRangesState) Descriptor

func (*IpRangesState) Descriptor() ([]byte, []int)

func (*IpRangesState) GetRange

func (m *IpRangesState) GetRange() []*ipreceiver.IpRange

func (*IpRangesState) ProtoMessage

func (*IpRangesState) ProtoMessage()

func (*IpRangesState) Reset

func (m *IpRangesState) Reset()

func (*IpRangesState) String

func (m *IpRangesState) String() string

func (*IpRangesState) XXX_DiscardUnknown

func (m *IpRangesState) XXX_DiscardUnknown()

func (*IpRangesState) XXX_Marshal

func (m *IpRangesState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IpRangesState) XXX_Merge

func (m *IpRangesState) XXX_Merge(src proto.Message)

func (*IpRangesState) XXX_Size

func (m *IpRangesState) XXX_Size() int

func (*IpRangesState) XXX_Unmarshal

func (m *IpRangesState) XXX_Unmarshal(b []byte) error

type IpamStateInterrogatorClient

type IpamStateInterrogatorClient interface {
	GetAllocatedSubnets(ctx context.Context, in *PrefixIdentifier, opts ...grpc.CallOption) (*SubnetsState, error)
	GetAllocatedRanges(ctx context.Context, in *PrefixIdentifier, opts ...grpc.CallOption) (*IpRangesState, error)
}

IpamStateInterrogatorClient is the client API for IpamStateInterrogator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewIpamStateInterrogatorClient

func NewIpamStateInterrogatorClient(cc *grpc.ClientConn) IpamStateInterrogatorClient

type IpamStateInterrogatorServer

type IpamStateInterrogatorServer interface {
	GetAllocatedSubnets(context.Context, *PrefixIdentifier) (*SubnetsState, error)
	GetAllocatedRanges(context.Context, *PrefixIdentifier) (*IpRangesState, error)
}

IpamStateInterrogatorServer is the server API for IpamStateInterrogator service.

type PrefixIdentifier

type PrefixIdentifier struct {
	Identifier           *ipreceiver.RangeIdentifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	AddrFamily           *ipprovider.IpFamily        `protobuf:"bytes,2,opt,name=addr_family,json=addrFamily,proto3" json:"addr_family,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*PrefixIdentifier) Descriptor

func (*PrefixIdentifier) Descriptor() ([]byte, []int)

func (*PrefixIdentifier) GetAddrFamily

func (m *PrefixIdentifier) GetAddrFamily() *ipprovider.IpFamily

func (*PrefixIdentifier) GetIdentifier

func (m *PrefixIdentifier) GetIdentifier() *ipreceiver.RangeIdentifier

func (*PrefixIdentifier) ProtoMessage

func (*PrefixIdentifier) ProtoMessage()

func (*PrefixIdentifier) Reset

func (m *PrefixIdentifier) Reset()

func (*PrefixIdentifier) String

func (m *PrefixIdentifier) String() string

func (*PrefixIdentifier) XXX_DiscardUnknown

func (m *PrefixIdentifier) XXX_DiscardUnknown()

func (*PrefixIdentifier) XXX_Marshal

func (m *PrefixIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrefixIdentifier) XXX_Merge

func (m *PrefixIdentifier) XXX_Merge(src proto.Message)

func (*PrefixIdentifier) XXX_Size

func (m *PrefixIdentifier) XXX_Size() int

func (*PrefixIdentifier) XXX_Unmarshal

func (m *PrefixIdentifier) XXX_Unmarshal(b []byte) error

type SubnetsState

type SubnetsState struct {
	Subnet               []*ipprovider.Subnet `protobuf:"bytes,1,rep,name=subnet,proto3" json:"subnet,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*SubnetsState) Descriptor

func (*SubnetsState) Descriptor() ([]byte, []int)

func (*SubnetsState) GetSubnet

func (m *SubnetsState) GetSubnet() []*ipprovider.Subnet

func (*SubnetsState) ProtoMessage

func (*SubnetsState) ProtoMessage()

func (*SubnetsState) Reset

func (m *SubnetsState) Reset()

func (*SubnetsState) String

func (m *SubnetsState) String() string

func (*SubnetsState) XXX_DiscardUnknown

func (m *SubnetsState) XXX_DiscardUnknown()

func (*SubnetsState) XXX_Marshal

func (m *SubnetsState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubnetsState) XXX_Merge

func (m *SubnetsState) XXX_Merge(src proto.Message)

func (*SubnetsState) XXX_Size

func (m *SubnetsState) XXX_Size() int

func (*SubnetsState) XXX_Unmarshal

func (m *SubnetsState) XXX_Unmarshal(b []byte) error

type UnimplementedIpamStateInterrogatorServer

type UnimplementedIpamStateInterrogatorServer struct {
}

UnimplementedIpamStateInterrogatorServer can be embedded to have forward compatible implementations.

func (*UnimplementedIpamStateInterrogatorServer) GetAllocatedRanges

func (*UnimplementedIpamStateInterrogatorServer) GetAllocatedRanges(ctx context.Context, req *PrefixIdentifier) (*IpRangesState, error)

func (*UnimplementedIpamStateInterrogatorServer) GetAllocatedSubnets

func (*UnimplementedIpamStateInterrogatorServer) GetAllocatedSubnets(ctx context.Context, req *PrefixIdentifier) (*SubnetsState, error)