admin

package
v0.8.32 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2022 License: Apache-2.0 Imports: 16 Imported by: 25

Documentation

Overview

Package admin is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var ConfigAdminClientFactory = func(cc *grpc.ClientConn) ConfigAdminServiceClient {
	return NewConfigAdminServiceClient(cc)
}

ConfigAdminClientFactory : Default ConfigAdminClient creation.

View Source 
var Type_name = map[int32]string{
	0: "NONE",
	1: "ADDED",
	2: "UPDATED",
	3: "REMOVED",
}
View Source 
var Type_value = map[string]int32{
	"NONE":    0,
	"ADDED":   1,
	"UPDATED": 2,
	"REMOVED": 3,
}

Functions

func RegisterConfigAdminServiceServer 

func RegisterConfigAdminServiceServer(s *grpc.Server, srv ConfigAdminServiceServer)

func RegisterConfigurationServiceServer added in v0.8.25 

func RegisterConfigurationServiceServer(s *grpc.Server, srv ConfigurationServiceServer)

func RegisterModelPluginServiceServer added in v0.8.1 

func RegisterModelPluginServiceServer(s *grpc.Server, srv ModelPluginServiceServer)

func RegisterTransactionServiceServer added in v0.8.25 

func RegisterTransactionServiceServer(s *grpc.Server, srv TransactionServiceServer)

Types

type Chunk 

type Chunk struct {
	// so_file is the name being streamed.
	SoFile string `protobuf:"bytes,1,opt,name=so_file,json=soFile,proto3" json:"so_file,omitempty"`
	// content is the bytes content.
	Content              []byte   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Chunk is for streaming a model plugin file to the server. There is a built in limit in gRPC of 4MB - plugin is usually around 20MB so break in to chunks of approx 1-2MB.

func (*Chunk) Descriptor 

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

func (*Chunk) GetContent 

func (m *Chunk) GetContent() []byte

func (*Chunk) GetSoFile 

func (m *Chunk) GetSoFile() string

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) String 

func (m *Chunk) String() string

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

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

func (*Chunk) XXX_Merge 

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

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

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

type CompactChangesRequest 

type CompactChangesRequest struct {
	// retention_period is an optional duration of time counting back from the present moment
	// Network changes that were created during this period should not be compacted
	// Any network changes that are older should be compacted
	// If not specified the duration is 0
	RetentionPeriod      *time.Duration `protobuf:"bytes,1,opt,name=retention_period,json=retentionPeriod,proto3,stdduration" json:"retention_period,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

CompactChangesRequest requests a compaction of the Network Change and Device Change stores

func (*CompactChangesRequest) Descriptor 

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

func (*CompactChangesRequest) GetRetentionPeriod 

func (m *CompactChangesRequest) GetRetentionPeriod() *time.Duration

func (*CompactChangesRequest) ProtoMessage 

func (*CompactChangesRequest) ProtoMessage()

func (*CompactChangesRequest) Reset 

func (m *CompactChangesRequest) Reset()

func (*CompactChangesRequest) String 

func (m *CompactChangesRequest) String() string

func (*CompactChangesRequest) XXX_DiscardUnknown 

func (m *CompactChangesRequest) XXX_DiscardUnknown()

func (*CompactChangesRequest) XXX_Marshal 

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

func (*CompactChangesRequest) XXX_Merge 

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

func (*CompactChangesRequest) XXX_Size 

func (m *CompactChangesRequest) XXX_Size() int

func (*CompactChangesRequest) XXX_Unmarshal 

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

type CompactChangesResponse 

type CompactChangesResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CompactChangesResponse is a response to the Compact Changes command

func (*CompactChangesResponse) Descriptor 

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

func (*CompactChangesResponse) ProtoMessage 

func (*CompactChangesResponse) ProtoMessage()

func (*CompactChangesResponse) Reset 

func (m *CompactChangesResponse) Reset()

func (*CompactChangesResponse) String 

func (m *CompactChangesResponse) String() string

func (*CompactChangesResponse) XXX_DiscardUnknown 

func (m *CompactChangesResponse) XXX_DiscardUnknown()

func (*CompactChangesResponse) XXX_Marshal 

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

func (*CompactChangesResponse) XXX_Merge 

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

func (*CompactChangesResponse) XXX_Size 

func (m *CompactChangesResponse) XXX_Size() int

func (*CompactChangesResponse) XXX_Unmarshal 

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

type ConfigAdminServiceClient 

type ConfigAdminServiceClient interface {
	// UploadRegisterModel uploads and adds the model plugin to the list of supported models.
	// The file is serialized in to Chunks of less than 4MB so as not to break the
	// gRPC byte array limit
	UploadRegisterModel(ctx context.Context, opts ...grpc.CallOption) (ConfigAdminService_UploadRegisterModelClient, error)
	// ListRegisteredModels returns a stream of registered models.
	ListRegisteredModels(ctx context.Context, in *ListModelsRequest, opts ...grpc.CallOption) (ConfigAdminService_ListRegisteredModelsClient, error)
	// RollbackNetworkChange rolls back the specified network change (or the latest one).
	RollbackNetworkChange(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error)
	// ListSnapshots gets a list of snapshots across all devices and versions,
	// and streams them back to the caller.
	ListSnapshots(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (ConfigAdminService_ListSnapshotsClient, error)
	// CompactChanges requests a snapshot of NetworkChange and DeviceChange stores.
	// This will take all of the Network Changes older than the retention period and
	// flatten them down to just one snapshot (replacing any older snapshot).
	// This will act as a baseline for those changes within the retention period and any future changes.
	// DeviceChanges will be snapshotted to correspond to these NetworkChange compactions
	// leaving an individual snapshot perv device and version combination.
	CompactChanges(ctx context.Context, in *CompactChangesRequest, opts ...grpc.CallOption) (*CompactChangesResponse, error)
}

ConfigAdminServiceClient is the client API for ConfigAdminService service.

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

func CreateConfigAdminServiceClient 

func CreateConfigAdminServiceClient(cc *grpc.ClientConn) ConfigAdminServiceClient

CreateConfigAdminServiceClient creates and returns a new config admin client

func NewConfigAdminServiceClient 

func NewConfigAdminServiceClient(cc *grpc.ClientConn) ConfigAdminServiceClient

type ConfigAdminServiceServer 

type ConfigAdminServiceServer interface {
	// UploadRegisterModel uploads and adds the model plugin to the list of supported models.
	// The file is serialized in to Chunks of less than 4MB so as not to break the
	// gRPC byte array limit
	UploadRegisterModel(ConfigAdminService_UploadRegisterModelServer) error
	// ListRegisteredModels returns a stream of registered models.
	ListRegisteredModels(*ListModelsRequest, ConfigAdminService_ListRegisteredModelsServer) error
	// RollbackNetworkChange rolls back the specified network change (or the latest one).
	RollbackNetworkChange(context.Context, *RollbackRequest) (*RollbackResponse, error)
	// ListSnapshots gets a list of snapshots across all devices and versions,
	// and streams them back to the caller.
	ListSnapshots(*ListSnapshotsRequest, ConfigAdminService_ListSnapshotsServer) error
	// CompactChanges requests a snapshot of NetworkChange and DeviceChange stores.
	// This will take all of the Network Changes older than the retention period and
	// flatten them down to just one snapshot (replacing any older snapshot).
	// This will act as a baseline for those changes within the retention period and any future changes.
	// DeviceChanges will be snapshotted to correspond to these NetworkChange compactions
	// leaving an individual snapshot perv device and version combination.
	CompactChanges(context.Context, *CompactChangesRequest) (*CompactChangesResponse, error)
}

ConfigAdminServiceServer is the server API for ConfigAdminService service.

type ConfigAdminService_ListRegisteredModelsClient 

type ConfigAdminService_ListRegisteredModelsClient interface {
	Recv() (*ModelPlugin, error)
	grpc.ClientStream
}

type ConfigAdminService_ListRegisteredModelsServer 

type ConfigAdminService_ListRegisteredModelsServer interface {
	Send(*ModelPlugin) error
	grpc.ServerStream
}

type ConfigAdminService_ListSnapshotsClient 

type ConfigAdminService_ListSnapshotsClient interface {
	Recv() (*device.Snapshot, error)
	grpc.ClientStream
}

type ConfigAdminService_ListSnapshotsServer 

type ConfigAdminService_ListSnapshotsServer interface {
	Send(*device.Snapshot) error
	grpc.ServerStream
}

type ConfigAdminService_UploadRegisterModelClient 

type ConfigAdminService_UploadRegisterModelClient interface {
	Send(*Chunk) error
	CloseAndRecv() (*RegisterResponse, error)
	grpc.ClientStream
}

type ConfigAdminService_UploadRegisterModelServer 

type ConfigAdminService_UploadRegisterModelServer interface {
	SendAndClose(*RegisterResponse) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type ConfigurationServiceClient added in v0.8.25 

type ConfigurationServiceClient interface {
	// Get configuration by its target ID
	GetConfiguration(ctx context.Context, in *GetConfigurationRequest, opts ...grpc.CallOption) (*GetConfigurationResponse, error)
	// List returns all target configurations
	ListConfigurations(ctx context.Context, in *ListConfigurationsRequest, opts ...grpc.CallOption) (ConfigurationService_ListConfigurationsClient, error)
	// Watch returns a stream of configuration change notifications
	WatchConfigurations(ctx context.Context, in *WatchConfigurationsRequest, opts ...grpc.CallOption) (ConfigurationService_WatchConfigurationsClient, error)
}

ConfigurationServiceClient is the client API for ConfigurationService service.

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

func NewConfigurationServiceClient added in v0.8.25 

func NewConfigurationServiceClient(cc *grpc.ClientConn) ConfigurationServiceClient

type ConfigurationServiceServer added in v0.8.25 

type ConfigurationServiceServer interface {
	// Get configuration by its target ID
	GetConfiguration(context.Context, *GetConfigurationRequest) (*GetConfigurationResponse, error)
	// List returns all target configurations
	ListConfigurations(*ListConfigurationsRequest, ConfigurationService_ListConfigurationsServer) error
	// Watch returns a stream of configuration change notifications
	WatchConfigurations(*WatchConfigurationsRequest, ConfigurationService_WatchConfigurationsServer) error
}

ConfigurationServiceServer is the server API for ConfigurationService service.

type ConfigurationService_ListConfigurationsClient added in v0.8.26 

type ConfigurationService_ListConfigurationsClient interface {
	Recv() (*ListConfigurationsResponse, error)
	grpc.ClientStream
}

type ConfigurationService_ListConfigurationsServer added in v0.8.26 

type ConfigurationService_ListConfigurationsServer interface {
	Send(*ListConfigurationsResponse) error
	grpc.ServerStream
}

type ConfigurationService_WatchConfigurationsClient added in v0.8.26 

type ConfigurationService_WatchConfigurationsClient interface {
	Recv() (*WatchConfigurationsResponse, error)
	grpc.ClientStream
}

type ConfigurationService_WatchConfigurationsServer added in v0.8.26 

type ConfigurationService_WatchConfigurationsServer interface {
	Send(*WatchConfigurationsResponse) error
	grpc.ServerStream
}

type GetConfigurationRequest added in v0.8.25 

type GetConfigurationRequest struct {
	TargetID             github_com_onosproject_onos_api_go_onos_config_v2.TargetID `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                                   `json:"-"`
	XXX_unrecognized     []byte                                                     `json:"-"`
	XXX_sizecache        int32                                                      `json:"-"`
}

func (*GetConfigurationRequest) Descriptor added in v0.8.25 

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

func (*GetConfigurationRequest) GetTargetID added in v0.8.27 

func (m *GetConfigurationRequest) GetTargetID() github_com_onosproject_onos_api_go_onos_config_v2.TargetID

func (*GetConfigurationRequest) ProtoMessage added in v0.8.25 

func (*GetConfigurationRequest) ProtoMessage()

func (*GetConfigurationRequest) Reset added in v0.8.25 

func (m *GetConfigurationRequest) Reset()

func (*GetConfigurationRequest) String added in v0.8.25 

func (m *GetConfigurationRequest) String() string

func (*GetConfigurationRequest) XXX_DiscardUnknown added in v0.8.25 

func (m *GetConfigurationRequest) XXX_DiscardUnknown()

func (*GetConfigurationRequest) XXX_Marshal added in v0.8.25 

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

func (*GetConfigurationRequest) XXX_Merge added in v0.8.25 

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

func (*GetConfigurationRequest) XXX_Size added in v0.8.25 

func (m *GetConfigurationRequest) XXX_Size() int

func (*GetConfigurationRequest) XXX_Unmarshal added in v0.8.25 

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

type GetConfigurationResponse added in v0.8.25 

type GetConfigurationResponse struct {
	Configuration        *v2.Configuration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetConfigurationResponse) Descriptor added in v0.8.25 

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

func (*GetConfigurationResponse) GetConfiguration added in v0.8.25 

func (m *GetConfigurationResponse) GetConfiguration() *v2.Configuration

func (*GetConfigurationResponse) ProtoMessage added in v0.8.25 

func (*GetConfigurationResponse) ProtoMessage()

func (*GetConfigurationResponse) Reset added in v0.8.25 

func (m *GetConfigurationResponse) Reset()

func (*GetConfigurationResponse) String added in v0.8.25 

func (m *GetConfigurationResponse) String() string

func (*GetConfigurationResponse) XXX_DiscardUnknown added in v0.8.25 

func (m *GetConfigurationResponse) XXX_DiscardUnknown()

func (*GetConfigurationResponse) XXX_Marshal added in v0.8.25 

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

func (*GetConfigurationResponse) XXX_Merge added in v0.8.25 

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

func (*GetConfigurationResponse) XXX_Size added in v0.8.25 

func (m *GetConfigurationResponse) XXX_Size() int

func (*GetConfigurationResponse) XXX_Unmarshal added in v0.8.25 

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

type GetTransactionRequest added in v0.8.25 

type GetTransactionRequest struct {
	ID                   github_com_onosproject_onos_api_go_onos_config_v2.TransactionID `` /* 130-byte string literal not displayed */
	Index                github_com_onosproject_onos_api_go_onos_config_v2.Index         `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                                        `json:"-"`
	XXX_unrecognized     []byte                                                          `json:"-"`
	XXX_sizecache        int32                                                           `json:"-"`
}

func (*GetTransactionRequest) Descriptor added in v0.8.25 

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

func (*GetTransactionRequest) GetID added in v0.8.25 

func (m *GetTransactionRequest) GetID() github_com_onosproject_onos_api_go_onos_config_v2.TransactionID

func (*GetTransactionRequest) GetIndex added in v0.8.25 

func (m *GetTransactionRequest) GetIndex() github_com_onosproject_onos_api_go_onos_config_v2.Index

func (*GetTransactionRequest) ProtoMessage added in v0.8.25 

func (*GetTransactionRequest) ProtoMessage()

func (*GetTransactionRequest) Reset added in v0.8.25 

func (m *GetTransactionRequest) Reset()

func (*GetTransactionRequest) String added in v0.8.25 

func (m *GetTransactionRequest) String() string

func (*GetTransactionRequest) XXX_DiscardUnknown added in v0.8.25 

func (m *GetTransactionRequest) XXX_DiscardUnknown()

func (*GetTransactionRequest) XXX_Marshal added in v0.8.25 

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

func (*GetTransactionRequest) XXX_Merge added in v0.8.25 

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

func (*GetTransactionRequest) XXX_Size added in v0.8.25 

func (m *GetTransactionRequest) XXX_Size() int

func (*GetTransactionRequest) XXX_Unmarshal added in v0.8.25 

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

type GetTransactionResponse added in v0.8.25 

type GetTransactionResponse struct {
	Transaction          *v2.Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetTransactionResponse) Descriptor added in v0.8.25 

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

func (*GetTransactionResponse) GetTransaction added in v0.8.25 

func (m *GetTransactionResponse) GetTransaction() *v2.Transaction

func (*GetTransactionResponse) ProtoMessage added in v0.8.25 

func (*GetTransactionResponse) ProtoMessage()

func (*GetTransactionResponse) Reset added in v0.8.25 

func (m *GetTransactionResponse) Reset()

func (*GetTransactionResponse) String added in v0.8.25 

func (m *GetTransactionResponse) String() string

func (*GetTransactionResponse) XXX_DiscardUnknown added in v0.8.25 

func (m *GetTransactionResponse) XXX_DiscardUnknown()

func (*GetTransactionResponse) XXX_Marshal added in v0.8.25 

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

func (*GetTransactionResponse) XXX_Merge added in v0.8.25 

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

func (*GetTransactionResponse) XXX_Size added in v0.8.25 

func (m *GetTransactionResponse) XXX_Size() int

func (*GetTransactionResponse) XXX_Unmarshal added in v0.8.25 

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

type ListConfigurationsRequest added in v0.8.25 

type ListConfigurationsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListConfigurationsRequest) Descriptor added in v0.8.25 

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

func (*ListConfigurationsRequest) ProtoMessage added in v0.8.25 

func (*ListConfigurationsRequest) ProtoMessage()

func (*ListConfigurationsRequest) Reset added in v0.8.25 

func (m *ListConfigurationsRequest) Reset()

func (*ListConfigurationsRequest) String added in v0.8.25 

func (m *ListConfigurationsRequest) String() string

func (*ListConfigurationsRequest) XXX_DiscardUnknown added in v0.8.25 

func (m *ListConfigurationsRequest) XXX_DiscardUnknown()

func (*ListConfigurationsRequest) XXX_Marshal added in v0.8.25 

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

func (*ListConfigurationsRequest) XXX_Merge added in v0.8.25 

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

func (*ListConfigurationsRequest) XXX_Size added in v0.8.25 

func (m *ListConfigurationsRequest) XXX_Size() int

func (*ListConfigurationsRequest) XXX_Unmarshal added in v0.8.25 

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

type ListConfigurationsResponse added in v0.8.25 

type ListConfigurationsResponse struct {
	Configuration        *v2.Configuration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ListConfigurationsResponse) Descriptor added in v0.8.25 

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

func (*ListConfigurationsResponse) GetConfiguration added in v0.8.25 

func (m *ListConfigurationsResponse) GetConfiguration() *v2.Configuration

func (*ListConfigurationsResponse) ProtoMessage added in v0.8.25 

func (*ListConfigurationsResponse) ProtoMessage()

func (*ListConfigurationsResponse) Reset added in v0.8.25 

func (m *ListConfigurationsResponse) Reset()

func (*ListConfigurationsResponse) String added in v0.8.25 

func (m *ListConfigurationsResponse) String() string

func (*ListConfigurationsResponse) XXX_DiscardUnknown added in v0.8.25 

func (m *ListConfigurationsResponse) XXX_DiscardUnknown()

func (*ListConfigurationsResponse) XXX_Marshal added in v0.8.25 

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

func (*ListConfigurationsResponse) XXX_Merge added in v0.8.25 

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

func (*ListConfigurationsResponse) XXX_Size added in v0.8.25 

func (m *ListConfigurationsResponse) XXX_Size() int

func (*ListConfigurationsResponse) XXX_Unmarshal added in v0.8.25 

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

type ListModelsRequest 

type ListModelsRequest struct {
	// verbose option causes all of the ReadWrite and ReadOnly paths to be included.
	Verbose bool `protobuf:"varint,1,opt,name=verbose,proto3" json:"verbose,omitempty"`
	// An optional filter on the name of the model plugins to list.
	ModelName string `protobuf:"bytes,2,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// An optional filter on the version of the model plugins to list
	ModelVersion         string   `protobuf:"bytes,3,opt,name=model_version,json=modelVersion,proto3" json:"model_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListModelsRequest carries data for querying registered model plugins.

func (*ListModelsRequest) Descriptor 

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

func (*ListModelsRequest) GetModelName 

func (m *ListModelsRequest) GetModelName() string

func (*ListModelsRequest) GetModelVersion 

func (m *ListModelsRequest) GetModelVersion() string

func (*ListModelsRequest) GetVerbose 

func (m *ListModelsRequest) GetVerbose() bool

func (*ListModelsRequest) ProtoMessage 

func (*ListModelsRequest) ProtoMessage()

func (*ListModelsRequest) Reset 

func (m *ListModelsRequest) Reset()

func (*ListModelsRequest) String 

func (m *ListModelsRequest) String() string

func (*ListModelsRequest) XXX_DiscardUnknown 

func (m *ListModelsRequest) XXX_DiscardUnknown()

func (*ListModelsRequest) XXX_Marshal 

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

func (*ListModelsRequest) XXX_Merge 

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

func (*ListModelsRequest) XXX_Size 

func (m *ListModelsRequest) XXX_Size() int

func (*ListModelsRequest) XXX_Unmarshal 

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

type ListSnapshotsRequest 

type ListSnapshotsRequest struct {
	// subscribe indicates whether to subscribe to events (e.g. ADD, UPDATE, and REMOVE) that occur
	// after all devices have been streamed to the client
	Subscribe bool `protobuf:"varint,1,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	// option to specify a specific device - if blank or '*' then select all
	// Can support `*` (match many chars) or '?' (match one char) as wildcard
	ID                   github_com_onosproject_onos_api_go_onos_config_snapshot_device.ID `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                                          `json:"-"`
	XXX_unrecognized     []byte                                                            `json:"-"`
	XXX_sizecache        int32                                                             `json:"-"`
}

ListSnapshotsRequest requests a list of snapshots for all devices and versions.

func (*ListSnapshotsRequest) Descriptor 

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

func (*ListSnapshotsRequest) GetID 

func (m *ListSnapshotsRequest) GetID() github_com_onosproject_onos_api_go_onos_config_snapshot_device.ID

func (*ListSnapshotsRequest) GetSubscribe 

func (m *ListSnapshotsRequest) GetSubscribe() bool

func (*ListSnapshotsRequest) ProtoMessage 

func (*ListSnapshotsRequest) ProtoMessage()

func (*ListSnapshotsRequest) Reset 

func (m *ListSnapshotsRequest) Reset()

func (*ListSnapshotsRequest) String 

func (m *ListSnapshotsRequest) String() string

func (*ListSnapshotsRequest) XXX_DiscardUnknown 

func (m *ListSnapshotsRequest) XXX_DiscardUnknown()

func (*ListSnapshotsRequest) XXX_Marshal 

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

func (*ListSnapshotsRequest) XXX_Merge 

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

func (*ListSnapshotsRequest) XXX_Size 

func (m *ListSnapshotsRequest) XXX_Size() int

func (*ListSnapshotsRequest) XXX_Unmarshal 

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

type ListTransactionsRequest added in v0.8.25 

type ListTransactionsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTransactionsRequest) Descriptor added in v0.8.25 

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

func (*ListTransactionsRequest) ProtoMessage added in v0.8.25 

func (*ListTransactionsRequest) ProtoMessage()

func (*ListTransactionsRequest) Reset added in v0.8.25 

func (m *ListTransactionsRequest) Reset()

func (*ListTransactionsRequest) String added in v0.8.25 

func (m *ListTransactionsRequest) String() string

func (*ListTransactionsRequest) XXX_DiscardUnknown added in v0.8.25 

func (m *ListTransactionsRequest) XXX_DiscardUnknown()

func (*ListTransactionsRequest) XXX_Marshal added in v0.8.25 

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

func (*ListTransactionsRequest) XXX_Merge added in v0.8.25 

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

func (*ListTransactionsRequest) XXX_Size added in v0.8.25 

func (m *ListTransactionsRequest) XXX_Size() int

func (*ListTransactionsRequest) XXX_Unmarshal added in v0.8.25 

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

type ListTransactionsResponse added in v0.8.25 

type ListTransactionsResponse struct {
	Transaction          *v2.Transaction `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListTransactionsResponse) Descriptor added in v0.8.25 

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

func (*ListTransactionsResponse) GetTransaction added in v0.8.25 

func (m *ListTransactionsResponse) GetTransaction() *v2.Transaction

func (*ListTransactionsResponse) ProtoMessage added in v0.8.25 

func (*ListTransactionsResponse) ProtoMessage()

func (*ListTransactionsResponse) Reset added in v0.8.25 

func (m *ListTransactionsResponse) Reset()

func (*ListTransactionsResponse) String added in v0.8.25 

func (m *ListTransactionsResponse) String() string

func (*ListTransactionsResponse) XXX_DiscardUnknown added in v0.8.25 

func (m *ListTransactionsResponse) XXX_DiscardUnknown()

func (*ListTransactionsResponse) XXX_Marshal added in v0.8.25 

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

func (*ListTransactionsResponse) XXX_Merge added in v0.8.25 

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

func (*ListTransactionsResponse) XXX_Size added in v0.8.25 

func (m *ListTransactionsResponse) XXX_Size() int

func (*ListTransactionsResponse) XXX_Unmarshal added in v0.8.25 

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

type MockConfigAdminServiceClient added in v0.6.11 

type MockConfigAdminServiceClient struct {
	// contains filtered or unexported fields
}

MockConfigAdminServiceClient is a mock of ConfigAdminServiceClient interface

func NewMockConfigAdminServiceClient added in v0.6.11 

func NewMockConfigAdminServiceClient(ctrl *gomock.Controller) *MockConfigAdminServiceClient

NewMockConfigAdminServiceClient creates a new mock instance

func (*MockConfigAdminServiceClient) CompactChanges added in v0.6.11 

func (m *MockConfigAdminServiceClient) CompactChanges(ctx context.Context, in *CompactChangesRequest, opts ...grpc.CallOption) (*CompactChangesResponse, error)

CompactChanges mocks base method

func (*MockConfigAdminServiceClient) EXPECT added in v0.6.11 

func (m *MockConfigAdminServiceClient) EXPECT() *MockConfigAdminServiceClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminServiceClient) ListRegisteredModels added in v0.6.11 

func (m *MockConfigAdminServiceClient) ListRegisteredModels(ctx context.Context, in *ListModelsRequest, opts ...grpc.CallOption) (ConfigAdminService_ListRegisteredModelsClient, error)

ListRegisteredModels mocks base method

func (*MockConfigAdminServiceClient) ListSnapshots added in v0.6.11 

func (m *MockConfigAdminServiceClient) ListSnapshots(ctx context.Context, in *ListSnapshotsRequest, opts ...grpc.CallOption) (ConfigAdminService_ListSnapshotsClient, error)

ListSnapshots mocks base method

func (*MockConfigAdminServiceClient) RollbackNetworkChange added in v0.6.11 

func (m *MockConfigAdminServiceClient) RollbackNetworkChange(ctx context.Context, in *RollbackRequest, opts ...grpc.CallOption) (*RollbackResponse, error)

RollbackNetworkChange mocks base method

func (*MockConfigAdminServiceClient) UploadRegisterModel added in v0.6.11 

func (m *MockConfigAdminServiceClient) UploadRegisterModel(ctx context.Context, opts ...grpc.CallOption) (ConfigAdminService_UploadRegisterModelClient, error)

UploadRegisterModel mocks base method

type MockConfigAdminServiceClientMockRecorder added in v0.6.11 

type MockConfigAdminServiceClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminServiceClientMockRecorder is the mock recorder for MockConfigAdminServiceClient

func (*MockConfigAdminServiceClientMockRecorder) CompactChanges added in v0.6.11 

func (mr *MockConfigAdminServiceClientMockRecorder) CompactChanges(ctx, in interface{}, opts ...interface{}) *gomock.Call

CompactChanges indicates an expected call of CompactChanges

func (*MockConfigAdminServiceClientMockRecorder) ListRegisteredModels added in v0.6.11 

func (mr *MockConfigAdminServiceClientMockRecorder) ListRegisteredModels(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListRegisteredModels indicates an expected call of ListRegisteredModels

func (*MockConfigAdminServiceClientMockRecorder) ListSnapshots added in v0.6.11 

func (mr *MockConfigAdminServiceClientMockRecorder) ListSnapshots(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListSnapshots indicates an expected call of ListSnapshots

func (*MockConfigAdminServiceClientMockRecorder) RollbackNetworkChange added in v0.6.11 

func (mr *MockConfigAdminServiceClientMockRecorder) RollbackNetworkChange(ctx, in interface{}, opts ...interface{}) *gomock.Call

RollbackNetworkChange indicates an expected call of RollbackNetworkChange

func (*MockConfigAdminServiceClientMockRecorder) UploadRegisterModel added in v0.6.11 

func (mr *MockConfigAdminServiceClientMockRecorder) UploadRegisterModel(ctx interface{}, opts ...interface{}) *gomock.Call

UploadRegisterModel indicates an expected call of UploadRegisterModel

type MockConfigAdminServiceServer added in v0.6.11 

type MockConfigAdminServiceServer struct {
	// contains filtered or unexported fields
}

MockConfigAdminServiceServer is a mock of ConfigAdminServiceServer interface

func NewMockConfigAdminServiceServer added in v0.6.11 

func NewMockConfigAdminServiceServer(ctrl *gomock.Controller) *MockConfigAdminServiceServer

NewMockConfigAdminServiceServer creates a new mock instance

func (*MockConfigAdminServiceServer) CompactChanges added in v0.6.11 

func (m *MockConfigAdminServiceServer) CompactChanges(arg0 context.Context, arg1 *CompactChangesRequest) (*CompactChangesResponse, error)

CompactChanges mocks base method

func (*MockConfigAdminServiceServer) EXPECT added in v0.6.11 

func (m *MockConfigAdminServiceServer) EXPECT() *MockConfigAdminServiceServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminServiceServer) ListRegisteredModels added in v0.6.11 

func (m *MockConfigAdminServiceServer) ListRegisteredModels(arg0 *ListModelsRequest, arg1 ConfigAdminService_ListRegisteredModelsServer) error

ListRegisteredModels mocks base method

func (*MockConfigAdminServiceServer) ListSnapshots added in v0.6.11 

func (m *MockConfigAdminServiceServer) ListSnapshots(arg0 *ListSnapshotsRequest, arg1 ConfigAdminService_ListSnapshotsServer) error

ListSnapshots mocks base method

func (*MockConfigAdminServiceServer) RollbackNetworkChange added in v0.6.11 

func (m *MockConfigAdminServiceServer) RollbackNetworkChange(arg0 context.Context, arg1 *RollbackRequest) (*RollbackResponse, error)

RollbackNetworkChange mocks base method

func (*MockConfigAdminServiceServer) UploadRegisterModel added in v0.6.11 

func (m *MockConfigAdminServiceServer) UploadRegisterModel(arg0 ConfigAdminService_UploadRegisterModelServer) error

UploadRegisterModel mocks base method

type MockConfigAdminServiceServerMockRecorder added in v0.6.11 

type MockConfigAdminServiceServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminServiceServerMockRecorder is the mock recorder for MockConfigAdminServiceServer

func (*MockConfigAdminServiceServerMockRecorder) CompactChanges added in v0.6.11 

func (mr *MockConfigAdminServiceServerMockRecorder) CompactChanges(arg0, arg1 interface{}) *gomock.Call

CompactChanges indicates an expected call of CompactChanges

func (*MockConfigAdminServiceServerMockRecorder) ListRegisteredModels added in v0.6.11 

func (mr *MockConfigAdminServiceServerMockRecorder) ListRegisteredModels(arg0, arg1 interface{}) *gomock.Call

ListRegisteredModels indicates an expected call of ListRegisteredModels

func (*MockConfigAdminServiceServerMockRecorder) ListSnapshots added in v0.6.11 

func (mr *MockConfigAdminServiceServerMockRecorder) ListSnapshots(arg0, arg1 interface{}) *gomock.Call

ListSnapshots indicates an expected call of ListSnapshots

func (*MockConfigAdminServiceServerMockRecorder) RollbackNetworkChange added in v0.6.11 

func (mr *MockConfigAdminServiceServerMockRecorder) RollbackNetworkChange(arg0, arg1 interface{}) *gomock.Call

RollbackNetworkChange indicates an expected call of RollbackNetworkChange

func (*MockConfigAdminServiceServerMockRecorder) UploadRegisterModel added in v0.6.11 

func (mr *MockConfigAdminServiceServerMockRecorder) UploadRegisterModel(arg0 interface{}) *gomock.Call

UploadRegisterModel indicates an expected call of UploadRegisterModel

type MockConfigAdminService_ListRegisteredModelsClient added in v0.6.11 

type MockConfigAdminService_ListRegisteredModelsClient struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListRegisteredModelsClient is a mock of ConfigAdminService_ListRegisteredModelsClient interface

func NewMockConfigAdminService_ListRegisteredModelsClient added in v0.6.11 

func NewMockConfigAdminService_ListRegisteredModelsClient(ctrl *gomock.Controller) *MockConfigAdminService_ListRegisteredModelsClient

NewMockConfigAdminService_ListRegisteredModelsClient creates a new mock instance

func (*MockConfigAdminService_ListRegisteredModelsClient) CloseSend added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsClient) CloseSend() error

CloseSend mocks base method

func (*MockConfigAdminService_ListRegisteredModelsClient) Context added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsClient) Context() context.Context

Context mocks base method

func (*MockConfigAdminService_ListRegisteredModelsClient) EXPECT added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsClient) EXPECT() *MockConfigAdminService_ListRegisteredModelsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminService_ListRegisteredModelsClient) Header added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockConfigAdminService_ListRegisteredModelsClient) Recv added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsClient) Recv() (*ModelInfo, error)

Recv mocks base method

func (*MockConfigAdminService_ListRegisteredModelsClient) RecvMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListRegisteredModelsClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockConfigAdminService_ListRegisteredModelsClient) SendMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListRegisteredModelsClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockConfigAdminService_ListRegisteredModelsClient) Trailer added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsClient) Trailer() metadata.MD

Trailer mocks base method

type MockConfigAdminService_ListRegisteredModelsClientMockRecorder added in v0.6.11 

type MockConfigAdminService_ListRegisteredModelsClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListRegisteredModelsClientMockRecorder is the mock recorder for MockConfigAdminService_ListRegisteredModelsClient

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) CloseSend added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Context added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Header added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Recv added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) SendMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Trailer added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockConfigAdminService_ListRegisteredModelsServer added in v0.6.11 

type MockConfigAdminService_ListRegisteredModelsServer struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListRegisteredModelsServer is a mock of ConfigAdminService_ListRegisteredModelsServer interface

func NewMockConfigAdminService_ListRegisteredModelsServer added in v0.6.11 

func NewMockConfigAdminService_ListRegisteredModelsServer(ctrl *gomock.Controller) *MockConfigAdminService_ListRegisteredModelsServer

NewMockConfigAdminService_ListRegisteredModelsServer creates a new mock instance

func (*MockConfigAdminService_ListRegisteredModelsServer) Context added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsServer) Context() context.Context

Context mocks base method

func (*MockConfigAdminService_ListRegisteredModelsServer) EXPECT added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsServer) EXPECT() *MockConfigAdminService_ListRegisteredModelsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminService_ListRegisteredModelsServer) RecvMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListRegisteredModelsServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockConfigAdminService_ListRegisteredModelsServer) Send added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsServer) Send(arg0 *ModelInfo) error

Send mocks base method

func (*MockConfigAdminService_ListRegisteredModelsServer) SendHeader added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockConfigAdminService_ListRegisteredModelsServer) SendMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListRegisteredModelsServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockConfigAdminService_ListRegisteredModelsServer) SetHeader added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockConfigAdminService_ListRegisteredModelsServer) SetTrailer added in v0.6.11 

func (m *MockConfigAdminService_ListRegisteredModelsServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockConfigAdminService_ListRegisteredModelsServerMockRecorder added in v0.6.11 

type MockConfigAdminService_ListRegisteredModelsServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListRegisteredModelsServerMockRecorder is the mock recorder for MockConfigAdminService_ListRegisteredModelsServer

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) Context added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) Send added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SendHeader added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SendMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SetHeader added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SetTrailer added in v0.6.11 

func (mr *MockConfigAdminService_ListRegisteredModelsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type MockConfigAdminService_ListSnapshotsClient added in v0.6.11 

type MockConfigAdminService_ListSnapshotsClient struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListSnapshotsClient is a mock of ConfigAdminService_ListSnapshotsClient interface

func NewMockConfigAdminService_ListSnapshotsClient added in v0.6.11 

func NewMockConfigAdminService_ListSnapshotsClient(ctrl *gomock.Controller) *MockConfigAdminService_ListSnapshotsClient

NewMockConfigAdminService_ListSnapshotsClient creates a new mock instance

func (*MockConfigAdminService_ListSnapshotsClient) CloseSend added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsClient) CloseSend() error

CloseSend mocks base method

func (*MockConfigAdminService_ListSnapshotsClient) Context added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsClient) Context() context.Context

Context mocks base method

func (*MockConfigAdminService_ListSnapshotsClient) EXPECT added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsClient) EXPECT() *MockConfigAdminService_ListSnapshotsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminService_ListSnapshotsClient) Header added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockConfigAdminService_ListSnapshotsClient) Recv added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsClient) Recv() (*device.Snapshot, error)

Recv mocks base method

func (*MockConfigAdminService_ListSnapshotsClient) RecvMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListSnapshotsClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockConfigAdminService_ListSnapshotsClient) SendMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListSnapshotsClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockConfigAdminService_ListSnapshotsClient) Trailer added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsClient) Trailer() metadata.MD

Trailer mocks base method

type MockConfigAdminService_ListSnapshotsClientMockRecorder added in v0.6.11 

type MockConfigAdminService_ListSnapshotsClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListSnapshotsClientMockRecorder is the mock recorder for MockConfigAdminService_ListSnapshotsClient

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) CloseSend added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) Context added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) Header added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) Recv added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) SendMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockConfigAdminService_ListSnapshotsClientMockRecorder) Trailer added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockConfigAdminService_ListSnapshotsServer added in v0.6.11 

type MockConfigAdminService_ListSnapshotsServer struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListSnapshotsServer is a mock of ConfigAdminService_ListSnapshotsServer interface

func NewMockConfigAdminService_ListSnapshotsServer added in v0.6.11 

func NewMockConfigAdminService_ListSnapshotsServer(ctrl *gomock.Controller) *MockConfigAdminService_ListSnapshotsServer

NewMockConfigAdminService_ListSnapshotsServer creates a new mock instance

func (*MockConfigAdminService_ListSnapshotsServer) Context added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsServer) Context() context.Context

Context mocks base method

func (*MockConfigAdminService_ListSnapshotsServer) EXPECT added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsServer) EXPECT() *MockConfigAdminService_ListSnapshotsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminService_ListSnapshotsServer) RecvMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListSnapshotsServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockConfigAdminService_ListSnapshotsServer) Send added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsServer) Send(arg0 *device.Snapshot) error

Send mocks base method

func (*MockConfigAdminService_ListSnapshotsServer) SendHeader added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockConfigAdminService_ListSnapshotsServer) SendMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_ListSnapshotsServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockConfigAdminService_ListSnapshotsServer) SetHeader added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockConfigAdminService_ListSnapshotsServer) SetTrailer added in v0.6.11 

func (m *MockConfigAdminService_ListSnapshotsServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockConfigAdminService_ListSnapshotsServerMockRecorder added in v0.6.11 

type MockConfigAdminService_ListSnapshotsServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_ListSnapshotsServerMockRecorder is the mock recorder for MockConfigAdminService_ListSnapshotsServer

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) Context added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) Send added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) SendHeader added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) SendMsg added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) SetHeader added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockConfigAdminService_ListSnapshotsServerMockRecorder) SetTrailer added in v0.6.11 

func (mr *MockConfigAdminService_ListSnapshotsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type MockConfigAdminService_UploadRegisterModelClient added in v0.6.11 

type MockConfigAdminService_UploadRegisterModelClient struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_UploadRegisterModelClient is a mock of ConfigAdminService_UploadRegisterModelClient interface

func NewMockConfigAdminService_UploadRegisterModelClient added in v0.6.11 

func NewMockConfigAdminService_UploadRegisterModelClient(ctrl *gomock.Controller) *MockConfigAdminService_UploadRegisterModelClient

NewMockConfigAdminService_UploadRegisterModelClient creates a new mock instance

func (*MockConfigAdminService_UploadRegisterModelClient) CloseAndRecv added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) CloseAndRecv() (*RegisterResponse, error)

CloseAndRecv mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) CloseSend added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) CloseSend() error

CloseSend mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) Context added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) Context() context.Context

Context mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) EXPECT added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) EXPECT() *MockConfigAdminService_UploadRegisterModelClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminService_UploadRegisterModelClient) Header added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) Header() (metadata.MD, error)

Header mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) RecvMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_UploadRegisterModelClient) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) Send added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) Send(arg0 *Chunk) error

Send mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) SendMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_UploadRegisterModelClient) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockConfigAdminService_UploadRegisterModelClient) Trailer added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelClient) Trailer() metadata.MD

Trailer mocks base method

type MockConfigAdminService_UploadRegisterModelClientMockRecorder added in v0.6.11 

type MockConfigAdminService_UploadRegisterModelClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_UploadRegisterModelClientMockRecorder is the mock recorder for MockConfigAdminService_UploadRegisterModelClient

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) CloseAndRecv added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) CloseAndRecv() *gomock.Call

CloseAndRecv indicates an expected call of CloseAndRecv

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) CloseSend added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) Context added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) Header added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) Send added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) SendMsg added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockConfigAdminService_UploadRegisterModelClientMockRecorder) Trailer added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer

type MockConfigAdminService_UploadRegisterModelServer added in v0.6.11 

type MockConfigAdminService_UploadRegisterModelServer struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_UploadRegisterModelServer is a mock of ConfigAdminService_UploadRegisterModelServer interface

func NewMockConfigAdminService_UploadRegisterModelServer added in v0.6.11 

func NewMockConfigAdminService_UploadRegisterModelServer(ctrl *gomock.Controller) *MockConfigAdminService_UploadRegisterModelServer

NewMockConfigAdminService_UploadRegisterModelServer creates a new mock instance

func (*MockConfigAdminService_UploadRegisterModelServer) Context added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) Context() context.Context

Context mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) EXPECT added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) EXPECT() *MockConfigAdminService_UploadRegisterModelServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockConfigAdminService_UploadRegisterModelServer) Recv added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) Recv() (*Chunk, error)

Recv mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) RecvMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_UploadRegisterModelServer) RecvMsg(m interface{}) error

RecvMsg mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) SendAndClose added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) SendAndClose(arg0 *RegisterResponse) error

SendAndClose mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) SendHeader added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) SendMsg added in v0.6.11 

func (m_2 *MockConfigAdminService_UploadRegisterModelServer) SendMsg(m interface{}) error

SendMsg mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) SetHeader added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockConfigAdminService_UploadRegisterModelServer) SetTrailer added in v0.6.11 

func (m *MockConfigAdminService_UploadRegisterModelServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockConfigAdminService_UploadRegisterModelServerMockRecorder added in v0.6.11 

type MockConfigAdminService_UploadRegisterModelServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConfigAdminService_UploadRegisterModelServerMockRecorder is the mock recorder for MockConfigAdminService_UploadRegisterModelServer

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) Context added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) Recv added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) RecvMsg added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) SendAndClose added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) SendAndClose(arg0 interface{}) *gomock.Call

SendAndClose indicates an expected call of SendAndClose

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) SendHeader added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) SendMsg added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) SetHeader added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockConfigAdminService_UploadRegisterModelServerMockRecorder) SetTrailer added in v0.6.11 

func (mr *MockConfigAdminService_UploadRegisterModelServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type ModelInfo 

type ModelInfo struct {
	// name is the name given to the model plugin - no spaces and title case.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// version is the semantic version of the Plugin e.g. 1.0.0.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// model_data is a set of metadata about the YANG files that went in to
	// generating the model plugin. It includes name, version and organization for
	// each YANG file, similar to how they are represented in gNMI Capabilities.
	ModelData []*gnmi.ModelData `protobuf:"bytes,3,rep,name=model_data,json=modelData,proto3" json:"model_data,omitempty"`
	// module is the name of the Model Plugin on the file system - usually ending in .so.<version>.
	Module string `protobuf:"bytes,4,opt,name=module,proto3" json:"module,omitempty"`
	// getStateMode is flag that defines how the "get state" operation works.
	//  0) means that no retrieval of state is attempted
	//  1) means that the synchronizer will make 2 requests to the device - one for
	//      Get with State and another for Get with Operational.
	//  2) means that the synchronizer will do a Get request comprising of each
	//      one of the ReadOnlyPaths and their sub paths. If there is a `list`
	//      in any one of these paths it will be sent down as is, expecting the
	//      devices implementation of gNMI will be able to expand wildcards.
	//  3) means that the synchronizer will do a Get request comprising of each
	//      one of the ReadOnlyPaths and their sub paths. If there is a `list`
	//      in any one of these paths, a separate call will be made first to find
	//      all the instances in the list and a Get including these expanded wildcards
	//      will be sent down to the device.
	GetStateMode uint32 `protobuf:"varint,5,opt,name=getStateMode,proto3" json:"getStateMode,omitempty"`
	// read_only_path is all of the read only paths for the model plugin.
	ReadOnlyPath []*ReadOnlyPath `protobuf:"bytes,7,rep,name=read_only_path,json=readOnlyPath,proto3" json:"read_only_path,omitempty"`
	// read_write_path is all of the read write paths for the model plugin.
	ReadWritePath        []*ReadWritePath `protobuf:"bytes,8,rep,name=read_write_path,json=readWritePath,proto3" json:"read_write_path,omitempty"`
	SupportedEncodings   []gnmi.Encoding  `` /* 142-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

ModelInfo is general information about a model plugin.

func (*ModelInfo) Descriptor 

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

func (*ModelInfo) GetGetStateMode 

func (m *ModelInfo) GetGetStateMode() uint32

func (*ModelInfo) GetModelData 

func (m *ModelInfo) GetModelData() []*gnmi.ModelData

func (*ModelInfo) GetModule 

func (m *ModelInfo) GetModule() string

func (*ModelInfo) GetName 

func (m *ModelInfo) GetName() string

func (*ModelInfo) GetReadOnlyPath 

func (m *ModelInfo) GetReadOnlyPath() []*ReadOnlyPath

func (*ModelInfo) GetReadWritePath 

func (m *ModelInfo) GetReadWritePath() []*ReadWritePath

func (*ModelInfo) GetSupportedEncodings added in v0.8.22 

func (m *ModelInfo) GetSupportedEncodings() []gnmi.Encoding

func (*ModelInfo) GetVersion 

func (m *ModelInfo) GetVersion() string

func (*ModelInfo) ProtoMessage 

func (*ModelInfo) ProtoMessage()

func (*ModelInfo) Reset 

func (m *ModelInfo) Reset()

func (*ModelInfo) String 

func (m *ModelInfo) String() string

func (*ModelInfo) XXX_DiscardUnknown 

func (m *ModelInfo) XXX_DiscardUnknown()

func (*ModelInfo) XXX_Marshal 

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

func (*ModelInfo) XXX_Merge 

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

func (*ModelInfo) XXX_Size 

func (m *ModelInfo) XXX_Size() int

func (*ModelInfo) XXX_Unmarshal 

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

type ModelInfoRequest added in v0.8.1 

type ModelInfoRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ModelInfoRequest carries request for the model information

func (*ModelInfoRequest) Descriptor added in v0.8.1 

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

func (*ModelInfoRequest) ProtoMessage added in v0.8.1 

func (*ModelInfoRequest) ProtoMessage()

func (*ModelInfoRequest) Reset added in v0.8.1 

func (m *ModelInfoRequest) Reset()

func (*ModelInfoRequest) String added in v0.8.1 

func (m *ModelInfoRequest) String() string

func (*ModelInfoRequest) XXX_DiscardUnknown added in v0.8.1 

func (m *ModelInfoRequest) XXX_DiscardUnknown()

func (*ModelInfoRequest) XXX_Marshal added in v0.8.1 

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

func (*ModelInfoRequest) XXX_Merge added in v0.8.1 

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

func (*ModelInfoRequest) XXX_Size added in v0.8.1 

func (m *ModelInfoRequest) XXX_Size() int

func (*ModelInfoRequest) XXX_Unmarshal added in v0.8.1 

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

type ModelInfoResponse added in v0.8.1 

type ModelInfoResponse struct {
	ModelInfo            *ModelInfo `protobuf:"bytes,1,opt,name=modelInfo,proto3" json:"modelInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

ModelInfoResponse carries response for the model information query

func (*ModelInfoResponse) Descriptor added in v0.8.1 

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

func (*ModelInfoResponse) GetModelInfo added in v0.8.1 

func (m *ModelInfoResponse) GetModelInfo() *ModelInfo

func (*ModelInfoResponse) ProtoMessage added in v0.8.1 

func (*ModelInfoResponse) ProtoMessage()

func (*ModelInfoResponse) Reset added in v0.8.1 

func (m *ModelInfoResponse) Reset()

func (*ModelInfoResponse) String added in v0.8.1 

func (m *ModelInfoResponse) String() string

func (*ModelInfoResponse) XXX_DiscardUnknown added in v0.8.1 

func (m *ModelInfoResponse) XXX_DiscardUnknown()

func (*ModelInfoResponse) XXX_Marshal added in v0.8.1 

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

func (*ModelInfoResponse) XXX_Merge added in v0.8.1 

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

func (*ModelInfoResponse) XXX_Size added in v0.8.1 

func (m *ModelInfoResponse) XXX_Size() int

func (*ModelInfoResponse) XXX_Unmarshal added in v0.8.1 

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

type ModelPlugin added in v0.8.25 

type ModelPlugin struct {
	Id                   string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Endpoint             string     `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Info                 *ModelInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Status               string     `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	Error                string     `protobuf:"bytes,11,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ModelPlugin) Descriptor added in v0.8.25 

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

func (*ModelPlugin) GetEndpoint added in v0.8.30 

func (m *ModelPlugin) GetEndpoint() string

func (*ModelPlugin) GetError added in v0.8.25 

func (m *ModelPlugin) GetError() string

func (*ModelPlugin) GetId added in v0.8.25 

func (m *ModelPlugin) GetId() string

func (*ModelPlugin) GetInfo added in v0.8.25 

func (m *ModelPlugin) GetInfo() *ModelInfo

func (*ModelPlugin) GetStatus added in v0.8.25 

func (m *ModelPlugin) GetStatus() string

func (*ModelPlugin) ProtoMessage added in v0.8.25 

func (*ModelPlugin) ProtoMessage()

func (*ModelPlugin) Reset added in v0.8.25 

func (m *ModelPlugin) Reset()

func (*ModelPlugin) String added in v0.8.25 

func (m *ModelPlugin) String() string

func (*ModelPlugin) XXX_DiscardUnknown added in v0.8.25 

func (m *ModelPlugin) XXX_DiscardUnknown()

func (*ModelPlugin) XXX_Marshal added in v0.8.25 

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

func (*ModelPlugin) XXX_Merge added in v0.8.25 

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

func (*ModelPlugin) XXX_Size added in v0.8.25 

func (m *ModelPlugin) XXX_Size() int

func (*ModelPlugin) XXX_Unmarshal added in v0.8.25 

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

type ModelPluginServiceClient added in v0.8.1 

type ModelPluginServiceClient interface {
	// GetModelInfo provides information about the model
	GetModelInfo(ctx context.Context, in *ModelInfoRequest, opts ...grpc.CallOption) (*ModelInfoResponse, error)
	// ValidateConfig validates the provided configuration data against the model
	ValidateConfig(ctx context.Context, in *ValidateConfigRequest, opts ...grpc.CallOption) (*ValidateConfigResponse, error)
	// GetPathValues produces list of typed path value entries from the specified configuration change JSON tree
	GetPathValues(ctx context.Context, in *PathValuesRequest, opts ...grpc.CallOption) (*PathValuesResponse, error)
}

ModelPluginServiceClient is the client API for ModelPluginService service.

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

func NewModelPluginServiceClient added in v0.8.1 

func NewModelPluginServiceClient(cc *grpc.ClientConn) ModelPluginServiceClient

type ModelPluginServiceServer added in v0.8.1 

type ModelPluginServiceServer interface {
	// GetModelInfo provides information about the model
	GetModelInfo(context.Context, *ModelInfoRequest) (*ModelInfoResponse, error)
	// ValidateConfig validates the provided configuration data against the model
	ValidateConfig(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)
	// GetPathValues produces list of typed path value entries from the specified configuration change JSON tree
	GetPathValues(context.Context, *PathValuesRequest) (*PathValuesResponse, error)
}

ModelPluginServiceServer is the server API for ModelPluginService service.

type PathValuesRequest added in v0.8.13 

type PathValuesRequest struct {
	PathPrefix           string   `protobuf:"bytes,1,opt,name=pathPrefix,proto3" json:"pathPrefix,omitempty"`
	Json                 []byte   `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PathValuesRequest carries configuration change as a JSON blob

func (*PathValuesRequest) Descriptor added in v0.8.13 

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

func (*PathValuesRequest) GetJson added in v0.8.13 

func (m *PathValuesRequest) GetJson() []byte

func (*PathValuesRequest) GetPathPrefix added in v0.8.13 

func (m *PathValuesRequest) GetPathPrefix() string

func (*PathValuesRequest) ProtoMessage added in v0.8.13 

func (*PathValuesRequest) ProtoMessage()

func (*PathValuesRequest) Reset added in v0.8.13 

func (m *PathValuesRequest) Reset()

func (*PathValuesRequest) String added in v0.8.13 

func (m *PathValuesRequest) String() string

func (*PathValuesRequest) XXX_DiscardUnknown added in v0.8.13 

func (m *PathValuesRequest) XXX_DiscardUnknown()

func (*PathValuesRequest) XXX_Marshal added in v0.8.13 

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

func (*PathValuesRequest) XXX_Merge added in v0.8.13 

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

func (*PathValuesRequest) XXX_Size added in v0.8.13 

func (m *PathValuesRequest) XXX_Size() int

func (*PathValuesRequest) XXX_Unmarshal added in v0.8.13 

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

type PathValuesResponse added in v0.8.13 

type PathValuesResponse struct {
	PathValues           []*v2.PathValue `protobuf:"bytes,1,rep,name=pathValues,proto3" json:"pathValues,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

PathValuesResponse carries a list of typed path values

func (*PathValuesResponse) Descriptor added in v0.8.13 

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

func (*PathValuesResponse) GetPathValues added in v0.8.13 

func (m *PathValuesResponse) GetPathValues() []*v2.PathValue

func (*PathValuesResponse) ProtoMessage added in v0.8.13 

func (*PathValuesResponse) ProtoMessage()

func (*PathValuesResponse) Reset added in v0.8.13 

func (m *PathValuesResponse) Reset()

func (*PathValuesResponse) String added in v0.8.13 

func (m *PathValuesResponse) String() string

func (*PathValuesResponse) XXX_DiscardUnknown added in v0.8.13 

func (m *PathValuesResponse) XXX_DiscardUnknown()

func (*PathValuesResponse) XXX_Marshal added in v0.8.13 

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

func (*PathValuesResponse) XXX_Merge added in v0.8.13 

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

func (*PathValuesResponse) XXX_Size added in v0.8.13 

func (m *PathValuesResponse) XXX_Size() int

func (*PathValuesResponse) XXX_Unmarshal added in v0.8.13 

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

type ReadOnlyPath 

type ReadOnlyPath struct {
	// path of the topmost `config false` object e.g. /cont1a/cont1b-state
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// ReadOnlySubPath is a set of children of the path including an entry for the
	// type of the topmost object with subpath `/`
	// An example is /list2b/index
	SubPath              []*ReadOnlySubPath `protobuf:"bytes,2,rep,name=sub_path,json=subPath,proto3" json:"sub_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

ReadOnlyPath extracted from the model plugin as the definition of a tree of read only items. In YANG models items are defined as ReadOnly with the `config false` keyword. This can be applied to single items (leafs) or collections (containers or lists). When this `config false` is applied to an object every item beneath it will also become readonly - here these are shown as subpaths. The complete read only path then will be a concatenation of both e.g. /cont1a/cont1b-state/list2b/index and the type is defined in the SubPath as UInt8.

func (*ReadOnlyPath) Descriptor 

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

func (*ReadOnlyPath) GetPath 

func (m *ReadOnlyPath) GetPath() string

func (*ReadOnlyPath) GetSubPath 

func (m *ReadOnlyPath) GetSubPath() []*ReadOnlySubPath

func (*ReadOnlyPath) ProtoMessage 

func (*ReadOnlyPath) ProtoMessage()

func (*ReadOnlyPath) Reset 

func (m *ReadOnlyPath) Reset()

func (*ReadOnlyPath) String 

func (m *ReadOnlyPath) String() string

func (*ReadOnlyPath) XXX_DiscardUnknown 

func (m *ReadOnlyPath) XXX_DiscardUnknown()

func (*ReadOnlyPath) XXX_Marshal 

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

func (*ReadOnlyPath) XXX_Merge 

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

func (*ReadOnlyPath) XXX_Size 

func (m *ReadOnlyPath) XXX_Size() int

func (*ReadOnlyPath) XXX_Unmarshal 

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

type ReadOnlySubPath 

type ReadOnlySubPath struct {
	// sub_path is the relative path of a child object e.g. /list2b/index
	SubPath string `protobuf:"bytes,1,opt,name=sub_path,json=subPath,proto3" json:"sub_path,omitempty"`
	// value_type is the datatype of the read only path
	ValueType            v2.ValueType `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=onos.config.v2.ValueType" json:"value_type,omitempty"`
	TypeOpts             []uint64     `protobuf:"varint,3,rep,packed,name=type_opts,json=typeOpts,proto3" json:"type_opts,omitempty"`
	Description          string       `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Units                string       `protobuf:"bytes,5,opt,name=units,proto3" json:"units,omitempty"`
	IsAKey               bool         `protobuf:"varint,6,opt,name=IsAKey,proto3" json:"IsAKey,omitempty"`
	AttrName             string       `protobuf:"bytes,7,opt,name=AttrName,proto3" json:"AttrName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ReadOnlySubPath is an extension to the ReadOnlyPath to define the datatype of the subpath

func (*ReadOnlySubPath) Descriptor 

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

func (*ReadOnlySubPath) GetAttrName added in v0.8.23 

func (m *ReadOnlySubPath) GetAttrName() string

func (*ReadOnlySubPath) GetDescription added in v0.8.23 

func (m *ReadOnlySubPath) GetDescription() string

func (*ReadOnlySubPath) GetIsAKey added in v0.8.23 

func (m *ReadOnlySubPath) GetIsAKey() bool

func (*ReadOnlySubPath) GetSubPath 

func (m *ReadOnlySubPath) GetSubPath() string

func (*ReadOnlySubPath) GetTypeOpts added in v0.8.23 

func (m *ReadOnlySubPath) GetTypeOpts() []uint64

func (*ReadOnlySubPath) GetUnits added in v0.8.23 

func (m *ReadOnlySubPath) GetUnits() string

func (*ReadOnlySubPath) GetValueType 

func (m *ReadOnlySubPath) GetValueType() v2.ValueType

func (*ReadOnlySubPath) ProtoMessage 

func (*ReadOnlySubPath) ProtoMessage()

func (*ReadOnlySubPath) Reset 

func (m *ReadOnlySubPath) Reset()

func (*ReadOnlySubPath) String 

func (m *ReadOnlySubPath) String() string

func (*ReadOnlySubPath) XXX_DiscardUnknown 

func (m *ReadOnlySubPath) XXX_DiscardUnknown()

func (*ReadOnlySubPath) XXX_Marshal 

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

func (*ReadOnlySubPath) XXX_Merge 

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

func (*ReadOnlySubPath) XXX_Size 

func (m *ReadOnlySubPath) XXX_Size() int

func (*ReadOnlySubPath) XXX_Unmarshal 

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

type ReadWritePath 

type ReadWritePath struct {
	// path is the full path to the attribute (leaf or leaf-list)
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// value_type is the data type of the attribute
	ValueType v2.ValueType `protobuf:"varint,2,opt,name=value_type,json=valueType,proto3,enum=onos.config.v2.ValueType" json:"value_type,omitempty"`
	// units is the unit of measurement e.g. dB, mV
	Units string `protobuf:"bytes,3,opt,name=units,proto3" json:"units,omitempty"`
	// description is an explaination of the meaning of the attribute
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// mandatory shows whether the attribute is optional (false) or required (true)
	Mandatory bool `protobuf:"varint,5,opt,name=mandatory,proto3" json:"mandatory,omitempty"`
	// default is a default value used with optional attributes
	Default string `protobuf:"bytes,6,opt,name=default,proto3" json:"default,omitempty"`
	// range is definition of the range of values a value is allowed
	Range []string `protobuf:"bytes,7,rep,name=range,proto3" json:"range,omitempty"`
	// length is a defintion of the length restrictions for the attribute
	Length               []string `protobuf:"bytes,8,rep,name=length,proto3" json:"length,omitempty"`
	TypeOpts             []uint64 `protobuf:"varint,9,rep,packed,name=type_opts,json=typeOpts,proto3" json:"type_opts,omitempty"`
	IsAKey               bool     `protobuf:"varint,10,opt,name=IsAKey,proto3" json:"IsAKey,omitempty"`
	AttrName             string   `protobuf:"bytes,11,opt,name=AttrName,proto3" json:"AttrName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ReadWritePath is extracted from the model plugin as the definition of a writeable attributes. In YANG models items are writable by default unless they are specified as `config false` or have an item with `config false` as a parent. Each configurable item has metadata with meanings taken from the YANG specification RFC 6020.

func (*ReadWritePath) Descriptor 

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

func (*ReadWritePath) GetAttrName added in v0.8.22 

func (m *ReadWritePath) GetAttrName() string

func (*ReadWritePath) GetDefault 

func (m *ReadWritePath) GetDefault() string

func (*ReadWritePath) GetDescription 

func (m *ReadWritePath) GetDescription() string

func (*ReadWritePath) GetIsAKey added in v0.8.22 

func (m *ReadWritePath) GetIsAKey() bool

func (*ReadWritePath) GetLength 

func (m *ReadWritePath) GetLength() []string

func (*ReadWritePath) GetMandatory 

func (m *ReadWritePath) GetMandatory() bool

func (*ReadWritePath) GetPath 

func (m *ReadWritePath) GetPath() string

func (*ReadWritePath) GetRange 

func (m *ReadWritePath) GetRange() []string

func (*ReadWritePath) GetTypeOpts added in v0.8.22 

func (m *ReadWritePath) GetTypeOpts() []uint64

func (*ReadWritePath) GetUnits 

func (m *ReadWritePath) GetUnits() string

func (*ReadWritePath) GetValueType 

func (m *ReadWritePath) GetValueType() v2.ValueType

func (*ReadWritePath) ProtoMessage 

func (*ReadWritePath) ProtoMessage()

func (*ReadWritePath) Reset 

func (m *ReadWritePath) Reset()

func (*ReadWritePath) String 

func (m *ReadWritePath) String() string

func (*ReadWritePath) XXX_DiscardUnknown 

func (m *ReadWritePath) XXX_DiscardUnknown()

func (*ReadWritePath) XXX_Marshal 

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

func (*ReadWritePath) XXX_Merge 

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

func (*ReadWritePath) XXX_Size 

func (m *ReadWritePath) XXX_Size() int

func (*ReadWritePath) XXX_Unmarshal 

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

type RegisterResponse 

type RegisterResponse struct {
	// name is name of the model plugin.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// version is the semantic version of the model plugin.
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RegisterResponse carries status of model plugin registration.

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) GetName 

func (m *RegisterResponse) GetName() string

func (*RegisterResponse) GetVersion 

func (m *RegisterResponse) GetVersion() string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

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

func (*RegisterResponse) XXX_Merge 

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

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

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

type RollbackRequest 

type RollbackRequest struct {
	// name is an optional name of a Network Change to rollback.
	// If no name is given the last network change will be rolled back.
	// If the name given is not of the last network change and error will be given.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// On optional comment to leave on the rollback.
	Comment              string   `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RollbackRequest carries the name of a network config to rollback. If there are subsequent changes to any of the devices in that config, the rollback will be rejected.

func (*RollbackRequest) Descriptor 

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

func (*RollbackRequest) GetComment 

func (m *RollbackRequest) GetComment() string

func (*RollbackRequest) GetName 

func (m *RollbackRequest) GetName() string

func (*RollbackRequest) ProtoMessage 

func (*RollbackRequest) ProtoMessage()

func (*RollbackRequest) Reset 

func (m *RollbackRequest) Reset()

func (*RollbackRequest) String 

func (m *RollbackRequest) String() string

func (*RollbackRequest) XXX_DiscardUnknown 

func (m *RollbackRequest) XXX_DiscardUnknown()

func (*RollbackRequest) XXX_Marshal 

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

func (*RollbackRequest) XXX_Merge 

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

func (*RollbackRequest) XXX_Size 

func (m *RollbackRequest) XXX_Size() int

func (*RollbackRequest) XXX_Unmarshal 

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

type RollbackResponse 

type RollbackResponse struct {
	// A message showing the result of the rollback.
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RollbackResponse carries the response of the rollback operation

func (*RollbackResponse) Descriptor 

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

func (*RollbackResponse) GetMessage 

func (m *RollbackResponse) GetMessage() string

func (*RollbackResponse) ProtoMessage 

func (*RollbackResponse) ProtoMessage()

func (*RollbackResponse) Reset 

func (m *RollbackResponse) Reset()

func (*RollbackResponse) String 

func (m *RollbackResponse) String() string

func (*RollbackResponse) XXX_DiscardUnknown 

func (m *RollbackResponse) XXX_DiscardUnknown()

func (*RollbackResponse) XXX_Marshal 

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

func (*RollbackResponse) XXX_Merge 

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

func (*RollbackResponse) XXX_Size 

func (m *RollbackResponse) XXX_Size() int

func (*RollbackResponse) XXX_Unmarshal 

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

type TransactionServiceClient added in v0.8.25 

type TransactionServiceClient interface {
	// Get transaction by its ID or index
	GetTransaction(ctx context.Context, in *GetTransactionRequest, opts ...grpc.CallOption) (*GetTransactionResponse, error)
	// List returns all configuration transactions
	ListTransactions(ctx context.Context, in *ListTransactionsRequest, opts ...grpc.CallOption) (TransactionService_ListTransactionsClient, error)
	// Watch returns a stream of configuration transaction change notifications
	WatchTransactions(ctx context.Context, in *WatchTransactionsRequest, opts ...grpc.CallOption) (TransactionService_WatchTransactionsClient, error)
}

TransactionServiceClient is the client API for TransactionService service.

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

func NewTransactionServiceClient added in v0.8.25 

func NewTransactionServiceClient(cc *grpc.ClientConn) TransactionServiceClient

type TransactionServiceServer added in v0.8.25 

type TransactionServiceServer interface {
	// Get transaction by its ID or index
	GetTransaction(context.Context, *GetTransactionRequest) (*GetTransactionResponse, error)
	// List returns all configuration transactions
	ListTransactions(*ListTransactionsRequest, TransactionService_ListTransactionsServer) error
	// Watch returns a stream of configuration transaction change notifications
	WatchTransactions(*WatchTransactionsRequest, TransactionService_WatchTransactionsServer) error
}

TransactionServiceServer is the server API for TransactionService service.

type TransactionService_ListTransactionsClient added in v0.8.26 

type TransactionService_ListTransactionsClient interface {
	Recv() (*ListTransactionsResponse, error)
	grpc.ClientStream
}

type TransactionService_ListTransactionsServer added in v0.8.26 

type TransactionService_ListTransactionsServer interface {
	Send(*ListTransactionsResponse) error
	grpc.ServerStream
}

type TransactionService_WatchTransactionsClient added in v0.8.26 

type TransactionService_WatchTransactionsClient interface {
	Recv() (*WatchTransactionsResponse, error)
	grpc.ClientStream
}

type TransactionService_WatchTransactionsServer added in v0.8.26 

type TransactionService_WatchTransactionsServer interface {
	Send(*WatchTransactionsResponse) error
	grpc.ServerStream
}

type Type 

type Type int32

Streaming event type 

const (
	// NONE indicates this response does not represent a state change
	Type_NONE Type = 0
	// ADDED is an event which occurs when an item is added
	Type_ADDED Type = 1
	// UPDATED is an event which occurs when an item is updated
	Type_UPDATED Type = 2
	// REMOVED is an event which occurs when an item is removed
	Type_REMOVED Type = 3
)

func (Type) EnumDescriptor 

func (Type) EnumDescriptor() ([]byte, []int)

func (Type) String 

func (x Type) String() string

type UnimplementedConfigAdminServiceServer 

type UnimplementedConfigAdminServiceServer struct {
}

UnimplementedConfigAdminServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedConfigAdminServiceServer) CompactChanges 

func (*UnimplementedConfigAdminServiceServer) CompactChanges(ctx context.Context, req *CompactChangesRequest) (*CompactChangesResponse, error)

func (*UnimplementedConfigAdminServiceServer) ListRegisteredModels 

func (*UnimplementedConfigAdminServiceServer) ListRegisteredModels(req *ListModelsRequest, srv ConfigAdminService_ListRegisteredModelsServer) error

func (*UnimplementedConfigAdminServiceServer) ListSnapshots 

func (*UnimplementedConfigAdminServiceServer) ListSnapshots(req *ListSnapshotsRequest, srv ConfigAdminService_ListSnapshotsServer) error

func (*UnimplementedConfigAdminServiceServer) RollbackNetworkChange 

func (*UnimplementedConfigAdminServiceServer) RollbackNetworkChange(ctx context.Context, req *RollbackRequest) (*RollbackResponse, error)

func (*UnimplementedConfigAdminServiceServer) UploadRegisterModel 

func (*UnimplementedConfigAdminServiceServer) UploadRegisterModel(srv ConfigAdminService_UploadRegisterModelServer) error

type UnimplementedConfigurationServiceServer added in v0.8.25 

type UnimplementedConfigurationServiceServer struct {
}

UnimplementedConfigurationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedConfigurationServiceServer) GetConfiguration added in v0.8.26 

func (*UnimplementedConfigurationServiceServer) GetConfiguration(ctx context.Context, req *GetConfigurationRequest) (*GetConfigurationResponse, error)

func (*UnimplementedConfigurationServiceServer) ListConfigurations added in v0.8.26 

func (*UnimplementedConfigurationServiceServer) ListConfigurations(req *ListConfigurationsRequest, srv ConfigurationService_ListConfigurationsServer) error

func (*UnimplementedConfigurationServiceServer) WatchConfigurations added in v0.8.26 

func (*UnimplementedConfigurationServiceServer) WatchConfigurations(req *WatchConfigurationsRequest, srv ConfigurationService_WatchConfigurationsServer) error

type UnimplementedModelPluginServiceServer added in v0.8.1 

type UnimplementedModelPluginServiceServer struct {
}

UnimplementedModelPluginServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedModelPluginServiceServer) GetModelInfo added in v0.8.1 

func (*UnimplementedModelPluginServiceServer) GetModelInfo(ctx context.Context, req *ModelInfoRequest) (*ModelInfoResponse, error)

func (*UnimplementedModelPluginServiceServer) GetPathValues added in v0.8.13 

func (*UnimplementedModelPluginServiceServer) GetPathValues(ctx context.Context, req *PathValuesRequest) (*PathValuesResponse, error)

func (*UnimplementedModelPluginServiceServer) ValidateConfig added in v0.8.1 

func (*UnimplementedModelPluginServiceServer) ValidateConfig(ctx context.Context, req *ValidateConfigRequest) (*ValidateConfigResponse, error)

type UnimplementedTransactionServiceServer added in v0.8.25 

type UnimplementedTransactionServiceServer struct {
}

UnimplementedTransactionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransactionServiceServer) GetTransaction added in v0.8.26 

func (*UnimplementedTransactionServiceServer) GetTransaction(ctx context.Context, req *GetTransactionRequest) (*GetTransactionResponse, error)

func (*UnimplementedTransactionServiceServer) ListTransactions added in v0.8.26 

func (*UnimplementedTransactionServiceServer) ListTransactions(req *ListTransactionsRequest, srv TransactionService_ListTransactionsServer) error

func (*UnimplementedTransactionServiceServer) WatchTransactions added in v0.8.26 

func (*UnimplementedTransactionServiceServer) WatchTransactions(req *WatchTransactionsRequest, srv TransactionService_WatchTransactionsServer) error

type ValidateConfigRequest added in v0.8.1 

type ValidateConfigRequest struct {
	Json                 []byte   `protobuf:"bytes,1,opt,name=json,proto3" json:"json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ValidateConfigRequest carries configuration data to be validated as a JSON blob

func (*ValidateConfigRequest) Descriptor added in v0.8.1 

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

func (*ValidateConfigRequest) GetJson added in v0.8.1 

func (m *ValidateConfigRequest) GetJson() []byte

func (*ValidateConfigRequest) ProtoMessage added in v0.8.1 

func (*ValidateConfigRequest) ProtoMessage()

func (*ValidateConfigRequest) Reset added in v0.8.1 

func (m *ValidateConfigRequest) Reset()

func (*ValidateConfigRequest) String added in v0.8.1 

func (m *ValidateConfigRequest) String() string

func (*ValidateConfigRequest) XXX_DiscardUnknown added in v0.8.1 

func (m *ValidateConfigRequest) XXX_DiscardUnknown()

func (*ValidateConfigRequest) XXX_Marshal added in v0.8.1 

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

func (*ValidateConfigRequest) XXX_Merge added in v0.8.1 

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

func (*ValidateConfigRequest) XXX_Size added in v0.8.1 

func (m *ValidateConfigRequest) XXX_Size() int

func (*ValidateConfigRequest) XXX_Unmarshal added in v0.8.1 

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

type ValidateConfigResponse added in v0.8.1 

type ValidateConfigResponse struct {
	Valid                bool     `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ValidateConfigResponse carries the result of the validation

func (*ValidateConfigResponse) Descriptor added in v0.8.1 

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

func (*ValidateConfigResponse) GetMessage added in v0.8.1 

func (m *ValidateConfigResponse) GetMessage() string

func (*ValidateConfigResponse) GetValid added in v0.8.1 

func (m *ValidateConfigResponse) GetValid() bool

func (*ValidateConfigResponse) ProtoMessage added in v0.8.1 

func (*ValidateConfigResponse) ProtoMessage()

func (*ValidateConfigResponse) Reset added in v0.8.1 

func (m *ValidateConfigResponse) Reset()

func (*ValidateConfigResponse) String added in v0.8.1 

func (m *ValidateConfigResponse) String() string

func (*ValidateConfigResponse) XXX_DiscardUnknown added in v0.8.1 

func (m *ValidateConfigResponse) XXX_DiscardUnknown()

func (*ValidateConfigResponse) XXX_Marshal added in v0.8.1 

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

func (*ValidateConfigResponse) XXX_Merge added in v0.8.1 

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

func (*ValidateConfigResponse) XXX_Size added in v0.8.1 

func (m *ValidateConfigResponse) XXX_Size() int

func (*ValidateConfigResponse) XXX_Unmarshal added in v0.8.1 

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

type WatchConfigurationsRequest added in v0.8.25 

type WatchConfigurationsRequest struct {
	Noreplay             bool     `protobuf:"varint,2,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchConfigurationsRequest) Descriptor added in v0.8.25 

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

func (*WatchConfigurationsRequest) GetNoreplay added in v0.8.29 

func (m *WatchConfigurationsRequest) GetNoreplay() bool

func (*WatchConfigurationsRequest) ProtoMessage added in v0.8.25 

func (*WatchConfigurationsRequest) ProtoMessage()

func (*WatchConfigurationsRequest) Reset added in v0.8.25 

func (m *WatchConfigurationsRequest) Reset()

func (*WatchConfigurationsRequest) String added in v0.8.25 

func (m *WatchConfigurationsRequest) String() string

func (*WatchConfigurationsRequest) XXX_DiscardUnknown added in v0.8.25 

func (m *WatchConfigurationsRequest) XXX_DiscardUnknown()

func (*WatchConfigurationsRequest) XXX_Marshal added in v0.8.25 

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

func (*WatchConfigurationsRequest) XXX_Merge added in v0.8.25 

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

func (*WatchConfigurationsRequest) XXX_Size added in v0.8.25 

func (m *WatchConfigurationsRequest) XXX_Size() int

func (*WatchConfigurationsRequest) XXX_Unmarshal added in v0.8.25 

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

type WatchConfigurationsResponse added in v0.8.25 

type WatchConfigurationsResponse struct {
	Event                v2.ConfigurationEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*WatchConfigurationsResponse) Descriptor added in v0.8.25 

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

func (*WatchConfigurationsResponse) GetEvent added in v0.8.25 

func (m *WatchConfigurationsResponse) GetEvent() v2.ConfigurationEvent

func (*WatchConfigurationsResponse) ProtoMessage added in v0.8.25 

func (*WatchConfigurationsResponse) ProtoMessage()

func (*WatchConfigurationsResponse) Reset added in v0.8.25 

func (m *WatchConfigurationsResponse) Reset()

func (*WatchConfigurationsResponse) String added in v0.8.25 

func (m *WatchConfigurationsResponse) String() string

func (*WatchConfigurationsResponse) XXX_DiscardUnknown added in v0.8.25 

func (m *WatchConfigurationsResponse) XXX_DiscardUnknown()

func (*WatchConfigurationsResponse) XXX_Marshal added in v0.8.25 

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

func (*WatchConfigurationsResponse) XXX_Merge added in v0.8.25 

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

func (*WatchConfigurationsResponse) XXX_Size added in v0.8.25 

func (m *WatchConfigurationsResponse) XXX_Size() int

func (*WatchConfigurationsResponse) XXX_Unmarshal added in v0.8.25 

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

type WatchTransactionsRequest added in v0.8.25 

type WatchTransactionsRequest struct {
	Noreplay             bool     `protobuf:"varint,2,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchTransactionsRequest) Descriptor added in v0.8.25 

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

func (*WatchTransactionsRequest) GetNoreplay added in v0.8.29 

func (m *WatchTransactionsRequest) GetNoreplay() bool

func (*WatchTransactionsRequest) ProtoMessage added in v0.8.25 

func (*WatchTransactionsRequest) ProtoMessage()

func (*WatchTransactionsRequest) Reset added in v0.8.25 

func (m *WatchTransactionsRequest) Reset()

func (*WatchTransactionsRequest) String added in v0.8.25 

func (m *WatchTransactionsRequest) String() string

func (*WatchTransactionsRequest) XXX_DiscardUnknown added in v0.8.25 

func (m *WatchTransactionsRequest) XXX_DiscardUnknown()

func (*WatchTransactionsRequest) XXX_Marshal added in v0.8.25 

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

func (*WatchTransactionsRequest) XXX_Merge added in v0.8.25 

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

func (*WatchTransactionsRequest) XXX_Size added in v0.8.25 

func (m *WatchTransactionsRequest) XXX_Size() int

func (*WatchTransactionsRequest) XXX_Unmarshal added in v0.8.25 

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

type WatchTransactionsResponse added in v0.8.25 

type WatchTransactionsResponse struct {
	Event                v2.TransactionEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*WatchTransactionsResponse) Descriptor added in v0.8.25 

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

func (*WatchTransactionsResponse) GetEvent added in v0.8.25 

func (m *WatchTransactionsResponse) GetEvent() v2.TransactionEvent

func (*WatchTransactionsResponse) ProtoMessage added in v0.8.25 

func (*WatchTransactionsResponse) ProtoMessage()

func (*WatchTransactionsResponse) Reset added in v0.8.25 

func (m *WatchTransactionsResponse) Reset()

func (*WatchTransactionsResponse) String added in v0.8.25 

func (m *WatchTransactionsResponse) String() string

func (*WatchTransactionsResponse) XXX_DiscardUnknown added in v0.8.25 

func (m *WatchTransactionsResponse) XXX_DiscardUnknown()

func (*WatchTransactionsResponse) XXX_Marshal added in v0.8.25 

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

func (*WatchTransactionsResponse) XXX_Merge added in v0.8.25 

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

func (*WatchTransactionsResponse) XXX_Size added in v0.8.25 

func (m *WatchTransactionsResponse) XXX_Size() int

func (*WatchTransactionsResponse) XXX_Unmarshal added in v0.8.25 

func (m *WatchTransactionsResponse) 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.