Documentation ¶
Index ¶
- func RegisterConfiguratorServer(s *grpc.Server, srv ConfiguratorServer)
- func RegisterStatsPollerServer(s *grpc.Server, srv StatsPollerServer)
- type Config
- func (*Config) Descriptor() ([]byte, []int)
- func (m *Config) GetLinuxConfig() *linux.ConfigData
- func (m *Config) GetNetallocConfig() *netalloc.ConfigData
- func (m *Config) GetVppConfig() *vpp.ConfigData
- func (*Config) ProtoMessage()
- func (m *Config) Reset()
- func (m *Config) String() string
- func (m *Config) XXX_DiscardUnknown()
- func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Config) XXX_Merge(src proto.Message)
- func (m *Config) XXX_Size() int
- func (m *Config) XXX_Unmarshal(b []byte) error
- type ConfiguratorClient
- type ConfiguratorServer
- type Configurator_NotifyClient
- type Configurator_NotifyServer
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)
- func (m *DeleteRequest) GetDelete() *Config
- func (*DeleteRequest) ProtoMessage()
- func (m *DeleteRequest) Reset()
- func (m *DeleteRequest) String() string
- func (m *DeleteRequest) XXX_DiscardUnknown()
- func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteRequest) XXX_Merge(src proto.Message)
- func (m *DeleteRequest) XXX_Size() int
- func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
- type DeleteResponse
- func (*DeleteResponse) Descriptor() ([]byte, []int)
- func (*DeleteResponse) ProtoMessage()
- func (m *DeleteResponse) Reset()
- func (m *DeleteResponse) String() string
- func (m *DeleteResponse) XXX_DiscardUnknown()
- func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteResponse) XXX_Merge(src proto.Message)
- func (m *DeleteResponse) XXX_Size() int
- func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
- type DumpRequest
- func (*DumpRequest) Descriptor() ([]byte, []int)
- func (*DumpRequest) ProtoMessage()
- func (m *DumpRequest) Reset()
- func (m *DumpRequest) String() string
- func (m *DumpRequest) XXX_DiscardUnknown()
- func (m *DumpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpRequest) XXX_Merge(src proto.Message)
- func (m *DumpRequest) XXX_Size() int
- func (m *DumpRequest) XXX_Unmarshal(b []byte) error
- type DumpResponse
- func (*DumpResponse) Descriptor() ([]byte, []int)
- func (m *DumpResponse) GetDump() *Config
- func (*DumpResponse) ProtoMessage()
- func (m *DumpResponse) Reset()
- func (m *DumpResponse) String() string
- func (m *DumpResponse) XXX_DiscardUnknown()
- func (m *DumpResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpResponse) XXX_Merge(src proto.Message)
- func (m *DumpResponse) XXX_Size() int
- func (m *DumpResponse) XXX_Unmarshal(b []byte) error
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) String() string
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetConfig() *Config
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) String() string
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)
- func (m *Notification) GetLinuxNotification() *linux.Notification
- func (m *Notification) GetNotification() isNotification_Notification
- func (m *Notification) GetVppNotification() *vpp.Notification
- func (*Notification) ProtoMessage()
- func (m *Notification) Reset()
- func (m *Notification) String() string
- func (m *Notification) XXX_DiscardUnknown()
- func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Notification) XXX_Merge(src proto.Message)
- func (*Notification) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Notification) XXX_Size() int
- func (m *Notification) XXX_Unmarshal(b []byte) error
- type NotificationRequest
- func (*NotificationRequest) Descriptor() ([]byte, []int)
- func (m *NotificationRequest) GetIdx() uint32
- func (*NotificationRequest) ProtoMessage()
- func (m *NotificationRequest) Reset()
- func (m *NotificationRequest) String() string
- func (m *NotificationRequest) XXX_DiscardUnknown()
- func (m *NotificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NotificationRequest) XXX_Merge(src proto.Message)
- func (m *NotificationRequest) XXX_Size() int
- func (m *NotificationRequest) XXX_Unmarshal(b []byte) error
- type NotificationResponse
- func (*NotificationResponse) Descriptor() ([]byte, []int)
- func (m *NotificationResponse) GetNextIdx() uint32
- func (m *NotificationResponse) GetNotification() *Notification
- func (*NotificationResponse) ProtoMessage()
- func (m *NotificationResponse) Reset()
- func (m *NotificationResponse) String() string
- func (m *NotificationResponse) XXX_DiscardUnknown()
- func (m *NotificationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NotificationResponse) XXX_Merge(src proto.Message)
- func (m *NotificationResponse) XXX_Size() int
- func (m *NotificationResponse) XXX_Unmarshal(b []byte) error
- type Notification_LinuxNotification
- type Notification_VppNotification
- type PollStatsRequest
- func (*PollStatsRequest) Descriptor() ([]byte, []int)
- func (m *PollStatsRequest) GetPeriodSec() uint32
- func (*PollStatsRequest) ProtoMessage()
- func (m *PollStatsRequest) Reset()
- func (m *PollStatsRequest) String() string
- func (m *PollStatsRequest) XXX_DiscardUnknown()
- func (m *PollStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PollStatsRequest) XXX_Merge(src proto.Message)
- func (m *PollStatsRequest) XXX_Size() int
- func (m *PollStatsRequest) XXX_Unmarshal(b []byte) error
- type PollStatsResponse
- func (*PollStatsResponse) Descriptor() ([]byte, []int)
- func (m *PollStatsResponse) GetPollSeq() uint32
- func (m *PollStatsResponse) GetStats() *Stats
- func (*PollStatsResponse) ProtoMessage()
- func (m *PollStatsResponse) Reset()
- func (m *PollStatsResponse) String() string
- func (m *PollStatsResponse) XXX_DiscardUnknown()
- func (m *PollStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PollStatsResponse) XXX_Merge(src proto.Message)
- func (m *PollStatsResponse) XXX_Size() int
- func (m *PollStatsResponse) XXX_Unmarshal(b []byte) error
- type Stats
- func (*Stats) Descriptor() ([]byte, []int)
- func (m *Stats) GetStats() isStats_Stats
- func (m *Stats) GetVppStats() *vpp.Stats
- func (*Stats) ProtoMessage()
- func (m *Stats) Reset()
- func (m *Stats) String() string
- func (m *Stats) XXX_DiscardUnknown()
- func (m *Stats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Stats) XXX_Merge(src proto.Message)
- func (*Stats) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Stats) XXX_Size() int
- func (m *Stats) XXX_Unmarshal(b []byte) error
- type StatsPollerClient
- type StatsPollerServer
- type StatsPoller_PollStatsClient
- type StatsPoller_PollStatsServer
- type Stats_VppStats
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)
- func (m *UpdateRequest) GetFullResync() bool
- func (m *UpdateRequest) GetUpdate() *Config
- func (*UpdateRequest) ProtoMessage()
- func (m *UpdateRequest) Reset()
- func (m *UpdateRequest) String() string
- func (m *UpdateRequest) XXX_DiscardUnknown()
- func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateRequest) XXX_Merge(src proto.Message)
- func (m *UpdateRequest) XXX_Size() int
- func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
- type UpdateResponse
- func (*UpdateResponse) Descriptor() ([]byte, []int)
- func (*UpdateResponse) ProtoMessage()
- func (m *UpdateResponse) Reset()
- func (m *UpdateResponse) String() string
- func (m *UpdateResponse) XXX_DiscardUnknown()
- func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateResponse) XXX_Merge(src proto.Message)
- func (m *UpdateResponse) XXX_Size() int
- func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterConfiguratorServer ¶
func RegisterConfiguratorServer(s *grpc.Server, srv ConfiguratorServer)
func RegisterStatsPollerServer ¶
func RegisterStatsPollerServer(s *grpc.Server, srv StatsPollerServer)
Types ¶
type Config ¶
type Config struct { VppConfig *vpp.ConfigData `protobuf:"bytes,1,opt,name=vpp_config,json=vppConfig,proto3" json:"vpp_config,omitempty"` LinuxConfig *linux.ConfigData `protobuf:"bytes,2,opt,name=linux_config,json=linuxConfig,proto3" json:"linux_config,omitempty"` NetallocConfig *netalloc.ConfigData `protobuf:"bytes,3,opt,name=netalloc_config,json=netallocConfig,proto3" json:"netalloc_config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Config groups all supported config data into single message.
func (*Config) Descriptor ¶
func (*Config) GetLinuxConfig ¶
func (m *Config) GetLinuxConfig() *linux.ConfigData
func (*Config) GetNetallocConfig ¶
func (m *Config) GetNetallocConfig() *netalloc.ConfigData
func (*Config) GetVppConfig ¶
func (m *Config) GetVppConfig() *vpp.ConfigData
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) XXX_DiscardUnknown ¶
func (m *Config) XXX_DiscardUnknown()
func (*Config) XXX_Marshal ¶
func (*Config) XXX_Unmarshal ¶
type ConfiguratorClient ¶
type ConfiguratorClient interface { // Get is used for listing desired config. Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) // Update is used for updating desired config. Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) // Delete is used for deleting desired config. Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) // Dump is used for dumping running config. Dump(ctx context.Context, in *DumpRequest, opts ...grpc.CallOption) (*DumpResponse, error) // Notify is used for subscribing to notifications. Notify(ctx context.Context, in *NotificationRequest, opts ...grpc.CallOption) (Configurator_NotifyClient, error) }
ConfiguratorClient is the client API for Configurator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewConfiguratorClient ¶
func NewConfiguratorClient(cc *grpc.ClientConn) ConfiguratorClient
type ConfiguratorServer ¶
type ConfiguratorServer interface { // Get is used for listing desired config. Get(context.Context, *GetRequest) (*GetResponse, error) // Update is used for updating desired config. Update(context.Context, *UpdateRequest) (*UpdateResponse, error) // Delete is used for deleting desired config. Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) // Dump is used for dumping running config. Dump(context.Context, *DumpRequest) (*DumpResponse, error) // Notify is used for subscribing to notifications. Notify(*NotificationRequest, Configurator_NotifyServer) error }
ConfiguratorServer is the server API for Configurator service.
type Configurator_NotifyClient ¶
type Configurator_NotifyClient interface { Recv() (*NotificationResponse, error) grpc.ClientStream }
type Configurator_NotifyServer ¶
type Configurator_NotifyServer interface { Send(*NotificationResponse) error grpc.ServerStream }
type DeleteRequest ¶
type DeleteRequest struct { // Delete describes config data to be deleted. Delete *Config `protobuf:"bytes,1,opt,name=delete,proto3" json:"delete,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteRequest) Descriptor ¶
func (*DeleteRequest) Descriptor() ([]byte, []int)
func (*DeleteRequest) GetDelete ¶
func (m *DeleteRequest) GetDelete() *Config
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
func (*DeleteRequest) XXX_DiscardUnknown ¶
func (m *DeleteRequest) XXX_DiscardUnknown()
func (*DeleteRequest) XXX_Marshal ¶
func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteRequest) XXX_Merge ¶
func (m *DeleteRequest) XXX_Merge(src proto.Message)
func (*DeleteRequest) XXX_Size ¶
func (m *DeleteRequest) XXX_Size() int
func (*DeleteRequest) XXX_Unmarshal ¶
func (m *DeleteRequest) XXX_Unmarshal(b []byte) error
type DeleteResponse ¶
type DeleteResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteResponse) Descriptor ¶
func (*DeleteResponse) Descriptor() ([]byte, []int)
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
func (*DeleteResponse) XXX_DiscardUnknown ¶
func (m *DeleteResponse) XXX_DiscardUnknown()
func (*DeleteResponse) XXX_Marshal ¶
func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteResponse) XXX_Merge ¶
func (m *DeleteResponse) XXX_Merge(src proto.Message)
func (*DeleteResponse) XXX_Size ¶
func (m *DeleteResponse) XXX_Size() int
func (*DeleteResponse) XXX_Unmarshal ¶
func (m *DeleteResponse) XXX_Unmarshal(b []byte) error
type DumpRequest ¶
type DumpRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpRequest) Descriptor ¶
func (*DumpRequest) Descriptor() ([]byte, []int)
func (*DumpRequest) ProtoMessage ¶
func (*DumpRequest) ProtoMessage()
func (*DumpRequest) Reset ¶
func (m *DumpRequest) Reset()
func (*DumpRequest) String ¶
func (m *DumpRequest) String() string
func (*DumpRequest) XXX_DiscardUnknown ¶
func (m *DumpRequest) XXX_DiscardUnknown()
func (*DumpRequest) XXX_Marshal ¶
func (m *DumpRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpRequest) XXX_Merge ¶
func (m *DumpRequest) XXX_Merge(src proto.Message)
func (*DumpRequest) XXX_Size ¶
func (m *DumpRequest) XXX_Size() int
func (*DumpRequest) XXX_Unmarshal ¶
func (m *DumpRequest) XXX_Unmarshal(b []byte) error
type DumpResponse ¶
type DumpResponse struct { // Dump describes running config dumped from southbound. Dump *Config `protobuf:"bytes,1,opt,name=dump,proto3" json:"dump,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DumpResponse) Descriptor ¶
func (*DumpResponse) Descriptor() ([]byte, []int)
func (*DumpResponse) GetDump ¶
func (m *DumpResponse) GetDump() *Config
func (*DumpResponse) ProtoMessage ¶
func (*DumpResponse) ProtoMessage()
func (*DumpResponse) Reset ¶
func (m *DumpResponse) Reset()
func (*DumpResponse) String ¶
func (m *DumpResponse) String() string
func (*DumpResponse) XXX_DiscardUnknown ¶
func (m *DumpResponse) XXX_DiscardUnknown()
func (*DumpResponse) XXX_Marshal ¶
func (m *DumpResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpResponse) XXX_Merge ¶
func (m *DumpResponse) XXX_Merge(src proto.Message)
func (*DumpResponse) XXX_Size ¶
func (m *DumpResponse) XXX_Size() int
func (*DumpResponse) XXX_Unmarshal ¶
func (m *DumpResponse) XXX_Unmarshal(b []byte) error
type GetRequest ¶
type GetRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct { // Config describes desired config retrieved from agent. Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetConfig ¶
func (m *GetResponse) GetConfig() *Config
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type Notification ¶
type Notification struct { // Types that are valid to be assigned to Notification: // *Notification_VppNotification // *Notification_LinuxNotification Notification isNotification_Notification `protobuf_oneof:"notification"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Notification groups all notification data into single message.
func (*Notification) Descriptor ¶
func (*Notification) Descriptor() ([]byte, []int)
func (*Notification) GetLinuxNotification ¶
func (m *Notification) GetLinuxNotification() *linux.Notification
func (*Notification) GetNotification ¶
func (m *Notification) GetNotification() isNotification_Notification
func (*Notification) GetVppNotification ¶
func (m *Notification) GetVppNotification() *vpp.Notification
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) Reset ¶
func (m *Notification) Reset()
func (*Notification) String ¶
func (m *Notification) String() string
func (*Notification) XXX_DiscardUnknown ¶
func (m *Notification) XXX_DiscardUnknown()
func (*Notification) XXX_Marshal ¶
func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Notification) XXX_Merge ¶
func (m *Notification) XXX_Merge(src proto.Message)
func (*Notification) XXX_OneofFuncs ¶
func (*Notification) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Notification) XXX_Size ¶
func (m *Notification) XXX_Size() int
func (*Notification) XXX_Unmarshal ¶
func (m *Notification) XXX_Unmarshal(b []byte) error
type NotificationRequest ¶
type NotificationRequest struct { Idx uint32 `protobuf:"varint,1,opt,name=idx,proto3" json:"idx,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
NotificationRequest represent a notification request which contains index of next required message
func (*NotificationRequest) Descriptor ¶
func (*NotificationRequest) Descriptor() ([]byte, []int)
func (*NotificationRequest) GetIdx ¶
func (m *NotificationRequest) GetIdx() uint32
func (*NotificationRequest) ProtoMessage ¶
func (*NotificationRequest) ProtoMessage()
func (*NotificationRequest) Reset ¶
func (m *NotificationRequest) Reset()
func (*NotificationRequest) String ¶
func (m *NotificationRequest) String() string
func (*NotificationRequest) XXX_DiscardUnknown ¶
func (m *NotificationRequest) XXX_DiscardUnknown()
func (*NotificationRequest) XXX_Marshal ¶
func (m *NotificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NotificationRequest) XXX_Merge ¶
func (m *NotificationRequest) XXX_Merge(src proto.Message)
func (*NotificationRequest) XXX_Size ¶
func (m *NotificationRequest) XXX_Size() int
func (*NotificationRequest) XXX_Unmarshal ¶
func (m *NotificationRequest) XXX_Unmarshal(b []byte) error
type NotificationResponse ¶
type NotificationResponse struct { // Index of following notification NextIdx uint32 `protobuf:"varint,1,opt,name=next_idx,json=nextIdx,proto3" json:"next_idx,omitempty"` // Notification data Notification *Notification `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response to notification request 'get'. Returns indexed notification.
func (*NotificationResponse) Descriptor ¶
func (*NotificationResponse) Descriptor() ([]byte, []int)
func (*NotificationResponse) GetNextIdx ¶
func (m *NotificationResponse) GetNextIdx() uint32
func (*NotificationResponse) GetNotification ¶
func (m *NotificationResponse) GetNotification() *Notification
func (*NotificationResponse) ProtoMessage ¶
func (*NotificationResponse) ProtoMessage()
func (*NotificationResponse) Reset ¶
func (m *NotificationResponse) Reset()
func (*NotificationResponse) String ¶
func (m *NotificationResponse) String() string
func (*NotificationResponse) XXX_DiscardUnknown ¶
func (m *NotificationResponse) XXX_DiscardUnknown()
func (*NotificationResponse) XXX_Marshal ¶
func (m *NotificationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NotificationResponse) XXX_Merge ¶
func (m *NotificationResponse) XXX_Merge(src proto.Message)
func (*NotificationResponse) XXX_Size ¶
func (m *NotificationResponse) XXX_Size() int
func (*NotificationResponse) XXX_Unmarshal ¶
func (m *NotificationResponse) XXX_Unmarshal(b []byte) error
type Notification_LinuxNotification ¶
type Notification_LinuxNotification struct {
LinuxNotification *linux.Notification `protobuf:"bytes,2,opt,name=linux_notification,json=linuxNotification,proto3,oneof"`
}
type Notification_VppNotification ¶
type Notification_VppNotification struct {
VppNotification *vpp.Notification `protobuf:"bytes,1,opt,name=vpp_notification,json=vppNotification,proto3,oneof"`
}
type PollStatsRequest ¶
type PollStatsRequest struct { // PeriodSec defines polling period (in seconds) PeriodSec uint32 `protobuf:"varint,1,opt,name=period_sec,json=periodSec,proto3" json:"period_sec,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PollStatsRequest) Descriptor ¶
func (*PollStatsRequest) Descriptor() ([]byte, []int)
func (*PollStatsRequest) GetPeriodSec ¶
func (m *PollStatsRequest) GetPeriodSec() uint32
func (*PollStatsRequest) ProtoMessage ¶
func (*PollStatsRequest) ProtoMessage()
func (*PollStatsRequest) Reset ¶
func (m *PollStatsRequest) Reset()
func (*PollStatsRequest) String ¶
func (m *PollStatsRequest) String() string
func (*PollStatsRequest) XXX_DiscardUnknown ¶
func (m *PollStatsRequest) XXX_DiscardUnknown()
func (*PollStatsRequest) XXX_Marshal ¶
func (m *PollStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PollStatsRequest) XXX_Merge ¶
func (m *PollStatsRequest) XXX_Merge(src proto.Message)
func (*PollStatsRequest) XXX_Size ¶
func (m *PollStatsRequest) XXX_Size() int
func (*PollStatsRequest) XXX_Unmarshal ¶
func (m *PollStatsRequest) XXX_Unmarshal(b []byte) error
type PollStatsResponse ¶
type PollStatsResponse struct { PollSeq uint32 `protobuf:"varint,1,opt,name=poll_seq,json=pollSeq,proto3" json:"poll_seq,omitempty"` Stats *Stats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PollStatsResponse) Descriptor ¶
func (*PollStatsResponse) Descriptor() ([]byte, []int)
func (*PollStatsResponse) GetPollSeq ¶
func (m *PollStatsResponse) GetPollSeq() uint32
func (*PollStatsResponse) GetStats ¶
func (m *PollStatsResponse) GetStats() *Stats
func (*PollStatsResponse) ProtoMessage ¶
func (*PollStatsResponse) ProtoMessage()
func (*PollStatsResponse) Reset ¶
func (m *PollStatsResponse) Reset()
func (*PollStatsResponse) String ¶
func (m *PollStatsResponse) String() string
func (*PollStatsResponse) XXX_DiscardUnknown ¶
func (m *PollStatsResponse) XXX_DiscardUnknown()
func (*PollStatsResponse) XXX_Marshal ¶
func (m *PollStatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PollStatsResponse) XXX_Merge ¶
func (m *PollStatsResponse) XXX_Merge(src proto.Message)
func (*PollStatsResponse) XXX_Size ¶
func (m *PollStatsResponse) XXX_Size() int
func (*PollStatsResponse) XXX_Unmarshal ¶
func (m *PollStatsResponse) XXX_Unmarshal(b []byte) error
type Stats ¶
type Stats struct { // Types that are valid to be assigned to Stats: // *Stats_VppStats Stats isStats_Stats `protobuf_oneof:"stats"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Stats) Descriptor ¶
func (*Stats) GetVppStats ¶
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) XXX_DiscardUnknown ¶
func (m *Stats) XXX_DiscardUnknown()
func (*Stats) XXX_Marshal ¶
func (*Stats) XXX_OneofFuncs ¶
func (*Stats) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Stats) XXX_Unmarshal ¶
type StatsPollerClient ¶
type StatsPollerClient interface { // PollStats is used for polling metrics using poll period. PollStats(ctx context.Context, in *PollStatsRequest, opts ...grpc.CallOption) (StatsPoller_PollStatsClient, error) }
StatsPollerClient is the client API for StatsPoller service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStatsPollerClient ¶
func NewStatsPollerClient(cc *grpc.ClientConn) StatsPollerClient
type StatsPollerServer ¶
type StatsPollerServer interface { // PollStats is used for polling metrics using poll period. PollStats(*PollStatsRequest, StatsPoller_PollStatsServer) error }
StatsPollerServer is the server API for StatsPoller service.
type StatsPoller_PollStatsClient ¶
type StatsPoller_PollStatsClient interface { Recv() (*PollStatsResponse, error) grpc.ClientStream }
type StatsPoller_PollStatsServer ¶
type StatsPoller_PollStatsServer interface { Send(*PollStatsResponse) error grpc.ServerStream }
type Stats_VppStats ¶
type UpdateRequest ¶
type UpdateRequest struct { // Update describes config data to be updated. Update *Config `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"` // The full_resync option can be used // to overwrite all existing data. FullResync bool `protobuf:"varint,2,opt,name=full_resync,json=fullResync,proto3" json:"full_resync,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateRequest) Descriptor ¶
func (*UpdateRequest) Descriptor() ([]byte, []int)
func (*UpdateRequest) GetFullResync ¶
func (m *UpdateRequest) GetFullResync() bool
func (*UpdateRequest) GetUpdate ¶
func (m *UpdateRequest) GetUpdate() *Config
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) Reset ¶
func (m *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (m *UpdateRequest) String() string
func (*UpdateRequest) XXX_DiscardUnknown ¶
func (m *UpdateRequest) XXX_DiscardUnknown()
func (*UpdateRequest) XXX_Marshal ¶
func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateRequest) XXX_Merge ¶
func (m *UpdateRequest) XXX_Merge(src proto.Message)
func (*UpdateRequest) XXX_Size ¶
func (m *UpdateRequest) XXX_Size() int
func (*UpdateRequest) XXX_Unmarshal ¶
func (m *UpdateRequest) XXX_Unmarshal(b []byte) error
type UpdateResponse ¶
type UpdateResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpdateResponse) Descriptor ¶
func (*UpdateResponse) Descriptor() ([]byte, []int)
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) Reset ¶
func (m *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (m *UpdateResponse) String() string
func (*UpdateResponse) XXX_DiscardUnknown ¶
func (m *UpdateResponse) XXX_DiscardUnknown()
func (*UpdateResponse) XXX_Marshal ¶
func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateResponse) XXX_Merge ¶
func (m *UpdateResponse) XXX_Merge(src proto.Message)
func (*UpdateResponse) XXX_Size ¶
func (m *UpdateResponse) XXX_Size() int
func (*UpdateResponse) XXX_Unmarshal ¶
func (m *UpdateResponse) XXX_Unmarshal(b []byte) error