admin

package
v0.7.106 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2021 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)

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() (*ModelInfo, error)
	grpc.ClientStream
}

type ConfigAdminService_ListRegisteredModelsServer 

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

type ConfigAdminService_ListSnapshotsClient 

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

type ConfigAdminService_ListSnapshotsServer 

type ConfigAdminService_ListSnapshotsServer interface {
	Send(*device1.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 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 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"`
	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) 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 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            device.ValueType `` /* 130-byte string literal not displayed */
	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) GetSubPath 

func (m *ReadOnlySubPath) GetSubPath() string

func (*ReadOnlySubPath) GetValueType 

func (m *ReadOnlySubPath) GetValueType() device.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 device.ValueType `` /* 130-byte string literal not displayed */
	// 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"`
	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) GetDefault 

func (m *ReadWritePath) GetDefault() string

func (*ReadWritePath) GetDescription 

func (m *ReadWritePath) GetDescription() string

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

func (m *ReadWritePath) GetUnits() string

func (*ReadWritePath) GetValueType 

func (m *ReadWritePath) GetValueType() device.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 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

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.