configurator

package
v2.5.0-alpha+incompatible Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2019 License: Apache-2.0 Imports: 10 Imported by: 69

Documentation

Index

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

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

func (*Notification) XXX_OneofWrappers() []interface{}

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

func (*Stats) GetStats 

func (m *Stats) GetStats() isStats_Stats

func (*Stats) GetVppStats 

func (m *Stats) GetVppStats() *vpp.Stats

func (*Stats) ProtoMessage 

func (*Stats) ProtoMessage()

func (*Stats) Reset 

func (m *Stats) Reset()

func (*Stats) String 

func (m *Stats) String() string

func (*Stats) XXX_DiscardUnknown 

func (m *Stats) XXX_DiscardUnknown()

func (*Stats) XXX_Marshal 

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

func (*Stats) XXX_Merge 

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

func (*Stats) XXX_OneofWrappers 

func (*Stats) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Stats) XXX_Size 

func (m *Stats) XXX_Size() int

func (*Stats) XXX_Unmarshal 

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

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 Stats_VppStats struct {
	VppStats *vpp.Stats `protobuf:"bytes,1,opt,name=vpp_stats,json=vppStats,proto3,oneof"`
}

type UnimplementedConfiguratorServer 

type UnimplementedConfiguratorServer struct {
}

UnimplementedConfiguratorServer can be embedded to have forward compatible implementations.

func (*UnimplementedConfiguratorServer) Delete 

func (*UnimplementedConfiguratorServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedConfiguratorServer) Dump 

func (*UnimplementedConfiguratorServer) Dump(ctx context.Context, req *DumpRequest) (*DumpResponse, error)

func (*UnimplementedConfiguratorServer) Get 

func (*UnimplementedConfiguratorServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedConfiguratorServer) Notify 

func (*UnimplementedConfiguratorServer) Notify(req *NotificationRequest, srv Configurator_NotifyServer) error

func (*UnimplementedConfiguratorServer) Update 

func (*UnimplementedConfiguratorServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error)

type UnimplementedStatsPollerServer 

type UnimplementedStatsPollerServer struct {
}

UnimplementedStatsPollerServer can be embedded to have forward compatible implementations.

func (*UnimplementedStatsPollerServer) PollStats 

func (*UnimplementedStatsPollerServer) PollStats(req *PollStatsRequest, srv StatsPoller_PollStatsServer) error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.