configurator

package
v2.2.0-beta+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 13, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterConfiguratorServer

func RegisterConfiguratorServer(s *grpc.Server, srv ConfiguratorServer)

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"`
	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) Descriptor() ([]byte, []int)

func (*Config) GetLinuxConfig

func (m *Config) GetLinuxConfig() *linux.ConfigData

func (*Config) GetVppConfig

func (m *Config) GetVppConfig() *vpp.ConfigData

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) Reset

func (m *Config) Reset()

func (*Config) String

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal

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

func (*Config) XXX_Merge

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

func (*Config) XXX_Size

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal

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

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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL