diags

package
v0.8.34 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

Package diags is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDiags        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDiags          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDiags = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ChangeServiceClientFactory = func(cc *grpc.ClientConn) ChangeServiceClient {
	return NewChangeServiceClient(cc)
}

ChangeServiceClientFactory : Default ChangeServiceClient creation.

View Source 
var OpStateDiagsClientFactory = func(cc *grpc.ClientConn) OpStateDiagsClient {
	return NewOpStateDiagsClient(cc)
}

OpStateDiagsClientFactory : Default OpStateDiagsClient 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 RegisterChangeServiceServer 

func RegisterChangeServiceServer(s *grpc.Server, srv ChangeServiceServer)

func RegisterOpStateDiagsServer 

func RegisterOpStateDiagsServer(s *grpc.Server, srv OpStateDiagsServer)

Types

type ChangeServiceClient 

type ChangeServiceClient interface {
	// List gets a stream of network change add/update/remove events for network
	// changes matching changeid
	ListNetworkChanges(ctx context.Context, in *ListNetworkChangeRequest, opts ...grpc.CallOption) (ChangeService_ListNetworkChangesClient, error)
	// List gets a stream of device change add/update/remove events for device
	// changes matching changeid
	ListDeviceChanges(ctx context.Context, in *ListDeviceChangeRequest, opts ...grpc.CallOption) (ChangeService_ListDeviceChangesClient, error)
}

ChangeServiceClient is the client API for ChangeService service.

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

func CreateChangeServiceClient 

func CreateChangeServiceClient(cc *grpc.ClientConn) ChangeServiceClient

CreateChangeServiceClient creates and returns a new change service client

func NewChangeServiceClient 

func NewChangeServiceClient(cc *grpc.ClientConn) ChangeServiceClient

type ChangeServiceServer 

type ChangeServiceServer interface {
	// List gets a stream of network change add/update/remove events for network
	// changes matching changeid
	ListNetworkChanges(*ListNetworkChangeRequest, ChangeService_ListNetworkChangesServer) error
	// List gets a stream of device change add/update/remove events for device
	// changes matching changeid
	ListDeviceChanges(*ListDeviceChangeRequest, ChangeService_ListDeviceChangesServer) error
}

ChangeServiceServer is the server API for ChangeService service.

type ChangeService_ListDeviceChangesClient 

type ChangeService_ListDeviceChangesClient interface {
	Recv() (*ListDeviceChangeResponse, error)
	grpc.ClientStream
}

type ChangeService_ListDeviceChangesServer 

type ChangeService_ListDeviceChangesServer interface {
	Send(*ListDeviceChangeResponse) error
	grpc.ServerStream
}

type ChangeService_ListNetworkChangesClient 

type ChangeService_ListNetworkChangesClient interface {
	Recv() (*ListNetworkChangeResponse, error)
	grpc.ClientStream
}

type ChangeService_ListNetworkChangesServer 

type ChangeService_ListNetworkChangesServer interface {
	Send(*ListNetworkChangeResponse) error
	grpc.ServerStream
}

type ListDeviceChangeRequest 

type ListDeviceChangeRequest 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 change - if blank or '*' then select all
	// Can support `*` (match many chars) or '?' (match one char) as wildcard
	DeviceID github_com_onosproject_onos_api_go_onos_config_device.ID `` /* 151-byte string literal not displayed */
	// device_version is an optional device version
	DeviceVersion github_com_onosproject_onos_api_go_onos_config_device.Version `` /* 171-byte string literal not displayed */
	// option to request only changes that happen after the call
	WithoutReplay bool `protobuf:"varint,4,opt,name=withoutReplay,proto3" json:"withoutReplay,omitempty"`
}

ListDeviceChangeRequest requests a stream of changes and updates to them By default, the request requests a stream of all changes that are present in the topology when the request is received by the service. However, if `subscribe` is `true`, the stream will remain open after all changes have been sent and events that occur following the last changes will be streamed to the client until the stream is closed. If "withoutReplay" is true then only changes that happen after the call will be returned

func (*ListDeviceChangeRequest) Descriptor 

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

func (*ListDeviceChangeRequest) GetDeviceID 

func (m *ListDeviceChangeRequest) GetDeviceID() github_com_onosproject_onos_api_go_onos_config_device.ID

func (*ListDeviceChangeRequest) GetDeviceVersion 

func (m *ListDeviceChangeRequest) GetDeviceVersion() github_com_onosproject_onos_api_go_onos_config_device.Version

func (*ListDeviceChangeRequest) GetSubscribe 

func (m *ListDeviceChangeRequest) GetSubscribe() bool

func (*ListDeviceChangeRequest) GetWithoutReplay 

func (m *ListDeviceChangeRequest) GetWithoutReplay() bool

func (*ListDeviceChangeRequest) Marshal 

func (m *ListDeviceChangeRequest) Marshal() (dAtA []byte, err error)

func (*ListDeviceChangeRequest) MarshalTo 

func (m *ListDeviceChangeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListDeviceChangeRequest) MarshalToSizedBuffer 

func (m *ListDeviceChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListDeviceChangeRequest) ProtoMessage 

func (*ListDeviceChangeRequest) ProtoMessage()

func (*ListDeviceChangeRequest) Reset 

func (m *ListDeviceChangeRequest) Reset()

func (*ListDeviceChangeRequest) Size 

func (m *ListDeviceChangeRequest) Size() (n int)

func (*ListDeviceChangeRequest) String 

func (m *ListDeviceChangeRequest) String() string

func (*ListDeviceChangeRequest) Unmarshal 

func (m *ListDeviceChangeRequest) Unmarshal(dAtA []byte) error

func (*ListDeviceChangeRequest) XXX_DiscardUnknown 

func (m *ListDeviceChangeRequest) XXX_DiscardUnknown()

func (*ListDeviceChangeRequest) XXX_Marshal 

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

func (*ListDeviceChangeRequest) XXX_Merge 

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

func (*ListDeviceChangeRequest) XXX_Size 

func (m *ListDeviceChangeRequest) XXX_Size() int

func (*ListDeviceChangeRequest) XXX_Unmarshal 

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

type ListDeviceChangeResponse 

type ListDeviceChangeResponse struct {
	// change is the device change on which the event occurred
	Change *device.DeviceChange `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// type is a qualification of the type of change being made
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=onos.config.diags.Type" json:"type,omitempty"`
}

ListDeviceChangeResponse carries a single network change event

func (*ListDeviceChangeResponse) Descriptor 

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

func (*ListDeviceChangeResponse) GetChange 

func (m *ListDeviceChangeResponse) GetChange() *device.DeviceChange

func (*ListDeviceChangeResponse) GetType 

func (m *ListDeviceChangeResponse) GetType() Type

func (*ListDeviceChangeResponse) Marshal 

func (m *ListDeviceChangeResponse) Marshal() (dAtA []byte, err error)

func (*ListDeviceChangeResponse) MarshalTo 

func (m *ListDeviceChangeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListDeviceChangeResponse) MarshalToSizedBuffer 

func (m *ListDeviceChangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListDeviceChangeResponse) ProtoMessage 

func (*ListDeviceChangeResponse) ProtoMessage()

func (*ListDeviceChangeResponse) Reset 

func (m *ListDeviceChangeResponse) Reset()

func (*ListDeviceChangeResponse) Size 

func (m *ListDeviceChangeResponse) Size() (n int)

func (*ListDeviceChangeResponse) String 

func (m *ListDeviceChangeResponse) String() string

func (*ListDeviceChangeResponse) Unmarshal 

func (m *ListDeviceChangeResponse) Unmarshal(dAtA []byte) error

func (*ListDeviceChangeResponse) XXX_DiscardUnknown 

func (m *ListDeviceChangeResponse) XXX_DiscardUnknown()

func (*ListDeviceChangeResponse) XXX_Marshal 

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

func (*ListDeviceChangeResponse) XXX_Merge 

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

func (*ListDeviceChangeResponse) XXX_Size 

func (m *ListDeviceChangeResponse) XXX_Size() int

func (*ListDeviceChangeResponse) XXX_Unmarshal 

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

type ListNetworkChangeRequest 

type ListNetworkChangeRequest 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 network change - if blank or '*' then select all
	// Can support `*` (match many chars) or '?' (match one char) as wildcard
	ChangeID github_com_onosproject_onos_api_go_onos_config_change_network.ID `` /* 143-byte string literal not displayed */
	// option to request only changes that happen after the call
	WithoutReplay bool `protobuf:"varint,3,opt,name=withoutReplay,proto3" json:"withoutReplay,omitempty"`
}

ListNetworkChangeRequest requests a stream of changes and updates to them By default, the request requests a stream of all changes that are present in the topology when the request is received by the service. However, if `subscribe` is `true`, the stream will remain open after all changes have been sent and events that occur following the last changes will be streamed to the client until the stream is closed. If "withoutReplay" is true then only changes that happen after the call will be returned

func (*ListNetworkChangeRequest) Descriptor 

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

func (*ListNetworkChangeRequest) GetChangeID 

func (m *ListNetworkChangeRequest) GetChangeID() github_com_onosproject_onos_api_go_onos_config_change_network.ID

func (*ListNetworkChangeRequest) GetSubscribe 

func (m *ListNetworkChangeRequest) GetSubscribe() bool

func (*ListNetworkChangeRequest) GetWithoutReplay 

func (m *ListNetworkChangeRequest) GetWithoutReplay() bool

func (*ListNetworkChangeRequest) Marshal 

func (m *ListNetworkChangeRequest) Marshal() (dAtA []byte, err error)

func (*ListNetworkChangeRequest) MarshalTo 

func (m *ListNetworkChangeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListNetworkChangeRequest) MarshalToSizedBuffer 

func (m *ListNetworkChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListNetworkChangeRequest) ProtoMessage 

func (*ListNetworkChangeRequest) ProtoMessage()

func (*ListNetworkChangeRequest) Reset 

func (m *ListNetworkChangeRequest) Reset()

func (*ListNetworkChangeRequest) Size 

func (m *ListNetworkChangeRequest) Size() (n int)

func (*ListNetworkChangeRequest) String 

func (m *ListNetworkChangeRequest) String() string

func (*ListNetworkChangeRequest) Unmarshal 

func (m *ListNetworkChangeRequest) Unmarshal(dAtA []byte) error

func (*ListNetworkChangeRequest) XXX_DiscardUnknown 

func (m *ListNetworkChangeRequest) XXX_DiscardUnknown()

func (*ListNetworkChangeRequest) XXX_Marshal 

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

func (*ListNetworkChangeRequest) XXX_Merge 

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

func (*ListNetworkChangeRequest) XXX_Size 

func (m *ListNetworkChangeRequest) XXX_Size() int

func (*ListNetworkChangeRequest) XXX_Unmarshal 

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

type ListNetworkChangeResponse 

type ListNetworkChangeResponse struct {
	// change is the network change on which the event occurred
	Change *network.NetworkChange `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// type is a qualification of the type of change being made
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=onos.config.diags.Type" json:"type,omitempty"`
}

ListNetworkChangeResponse carries a single network change event

func (*ListNetworkChangeResponse) Descriptor 

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

func (*ListNetworkChangeResponse) GetChange 

func (m *ListNetworkChangeResponse) GetChange() *network.NetworkChange

func (*ListNetworkChangeResponse) GetType 

func (m *ListNetworkChangeResponse) GetType() Type

func (*ListNetworkChangeResponse) Marshal 

func (m *ListNetworkChangeResponse) Marshal() (dAtA []byte, err error)

func (*ListNetworkChangeResponse) MarshalTo 

func (m *ListNetworkChangeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListNetworkChangeResponse) MarshalToSizedBuffer 

func (m *ListNetworkChangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListNetworkChangeResponse) ProtoMessage 

func (*ListNetworkChangeResponse) ProtoMessage()

func (*ListNetworkChangeResponse) Reset 

func (m *ListNetworkChangeResponse) Reset()

func (*ListNetworkChangeResponse) Size 

func (m *ListNetworkChangeResponse) Size() (n int)

func (*ListNetworkChangeResponse) String 

func (m *ListNetworkChangeResponse) String() string

func (*ListNetworkChangeResponse) Unmarshal 

func (m *ListNetworkChangeResponse) Unmarshal(dAtA []byte) error

func (*ListNetworkChangeResponse) XXX_DiscardUnknown 

func (m *ListNetworkChangeResponse) XXX_DiscardUnknown()

func (*ListNetworkChangeResponse) XXX_Marshal 

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

func (*ListNetworkChangeResponse) XXX_Merge 

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

func (*ListNetworkChangeResponse) XXX_Size 

func (m *ListNetworkChangeResponse) XXX_Size() int

func (*ListNetworkChangeResponse) XXX_Unmarshal 

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

type MockChangeServiceClient added in v0.6.11 

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

MockChangeServiceClient is a mock of ChangeServiceClient interface

func NewMockChangeServiceClient added in v0.6.11 

func NewMockChangeServiceClient(ctrl *gomock.Controller) *MockChangeServiceClient

NewMockChangeServiceClient creates a new mock instance

func (*MockChangeServiceClient) EXPECT added in v0.6.11 

func (m *MockChangeServiceClient) EXPECT() *MockChangeServiceClientMockRecorder

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

func (*MockChangeServiceClient) ListDeviceChanges added in v0.6.11 

func (m *MockChangeServiceClient) ListDeviceChanges(ctx context.Context, in *ListDeviceChangeRequest, opts ...grpc.CallOption) (ChangeService_ListDeviceChangesClient, error)

ListDeviceChanges mocks base method

func (*MockChangeServiceClient) ListNetworkChanges added in v0.6.11 

func (m *MockChangeServiceClient) ListNetworkChanges(ctx context.Context, in *ListNetworkChangeRequest, opts ...grpc.CallOption) (ChangeService_ListNetworkChangesClient, error)

ListNetworkChanges mocks base method

type MockChangeServiceClientMockRecorder added in v0.6.11 

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

MockChangeServiceClientMockRecorder is the mock recorder for MockChangeServiceClient

func (*MockChangeServiceClientMockRecorder) ListDeviceChanges added in v0.6.11 

func (mr *MockChangeServiceClientMockRecorder) ListDeviceChanges(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListDeviceChanges indicates an expected call of ListDeviceChanges

func (*MockChangeServiceClientMockRecorder) ListNetworkChanges added in v0.6.11 

func (mr *MockChangeServiceClientMockRecorder) ListNetworkChanges(ctx, in interface{}, opts ...interface{}) *gomock.Call

ListNetworkChanges indicates an expected call of ListNetworkChanges

type MockChangeServiceServer added in v0.6.11 

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

MockChangeServiceServer is a mock of ChangeServiceServer interface

func NewMockChangeServiceServer added in v0.6.11 

func NewMockChangeServiceServer(ctrl *gomock.Controller) *MockChangeServiceServer

NewMockChangeServiceServer creates a new mock instance

func (*MockChangeServiceServer) EXPECT added in v0.6.11 

func (m *MockChangeServiceServer) EXPECT() *MockChangeServiceServerMockRecorder

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

func (*MockChangeServiceServer) ListDeviceChanges added in v0.6.11 

func (m *MockChangeServiceServer) ListDeviceChanges(arg0 *ListDeviceChangeRequest, arg1 ChangeService_ListDeviceChangesServer) error

ListDeviceChanges mocks base method

func (*MockChangeServiceServer) ListNetworkChanges added in v0.6.11 

func (m *MockChangeServiceServer) ListNetworkChanges(arg0 *ListNetworkChangeRequest, arg1 ChangeService_ListNetworkChangesServer) error

ListNetworkChanges mocks base method

type MockChangeServiceServerMockRecorder added in v0.6.11 

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

MockChangeServiceServerMockRecorder is the mock recorder for MockChangeServiceServer

func (*MockChangeServiceServerMockRecorder) ListDeviceChanges added in v0.6.11 

func (mr *MockChangeServiceServerMockRecorder) ListDeviceChanges(arg0, arg1 interface{}) *gomock.Call

ListDeviceChanges indicates an expected call of ListDeviceChanges

func (*MockChangeServiceServerMockRecorder) ListNetworkChanges added in v0.6.11 

func (mr *MockChangeServiceServerMockRecorder) ListNetworkChanges(arg0, arg1 interface{}) *gomock.Call

ListNetworkChanges indicates an expected call of ListNetworkChanges

type MockChangeService_ListDeviceChangesClient added in v0.6.11 

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

MockChangeService_ListDeviceChangesClient is a mock of ChangeService_ListDeviceChangesClient interface

func NewMockChangeService_ListDeviceChangesClient added in v0.6.11 

func NewMockChangeService_ListDeviceChangesClient(ctrl *gomock.Controller) *MockChangeService_ListDeviceChangesClient

NewMockChangeService_ListDeviceChangesClient creates a new mock instance

func (*MockChangeService_ListDeviceChangesClient) CloseSend added in v0.6.11 

func (m *MockChangeService_ListDeviceChangesClient) CloseSend() error

CloseSend mocks base method

func (*MockChangeService_ListDeviceChangesClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockChangeService_ListDeviceChangesClient) EXPECT added in v0.6.11 

func (m *MockChangeService_ListDeviceChangesClient) EXPECT() *MockChangeService_ListDeviceChangesClientMockRecorder

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

func (*MockChangeService_ListDeviceChangesClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockChangeService_ListDeviceChangesClient) Recv added in v0.6.11 

func (m *MockChangeService_ListDeviceChangesClient) Recv() (*ListDeviceChangeResponse, error)

Recv mocks base method

func (*MockChangeService_ListDeviceChangesClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockChangeService_ListDeviceChangesClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockChangeService_ListDeviceChangesClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockChangeService_ListDeviceChangesClientMockRecorder added in v0.6.11 

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

MockChangeService_ListDeviceChangesClientMockRecorder is the mock recorder for MockChangeService_ListDeviceChangesClient

func (*MockChangeService_ListDeviceChangesClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockChangeService_ListDeviceChangesClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockChangeService_ListDeviceChangesClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockChangeService_ListDeviceChangesClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockChangeService_ListDeviceChangesClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockChangeService_ListDeviceChangesClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockChangeService_ListDeviceChangesClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockChangeService_ListDeviceChangesServer added in v0.6.11 

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

MockChangeService_ListDeviceChangesServer is a mock of ChangeService_ListDeviceChangesServer interface

func NewMockChangeService_ListDeviceChangesServer added in v0.6.11 

func NewMockChangeService_ListDeviceChangesServer(ctrl *gomock.Controller) *MockChangeService_ListDeviceChangesServer

NewMockChangeService_ListDeviceChangesServer creates a new mock instance

func (*MockChangeService_ListDeviceChangesServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockChangeService_ListDeviceChangesServer) EXPECT added in v0.6.11 

func (m *MockChangeService_ListDeviceChangesServer) EXPECT() *MockChangeService_ListDeviceChangesServerMockRecorder

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

func (*MockChangeService_ListDeviceChangesServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockChangeService_ListDeviceChangesServer) Send added in v0.6.11 

func (m *MockChangeService_ListDeviceChangesServer) Send(arg0 *ListDeviceChangeResponse) error

Send mocks base method

func (*MockChangeService_ListDeviceChangesServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockChangeService_ListDeviceChangesServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockChangeService_ListDeviceChangesServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockChangeService_ListDeviceChangesServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockChangeService_ListDeviceChangesServerMockRecorder added in v0.6.11 

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

MockChangeService_ListDeviceChangesServerMockRecorder is the mock recorder for MockChangeService_ListDeviceChangesServer

func (*MockChangeService_ListDeviceChangesServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockChangeService_ListDeviceChangesServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockChangeService_ListDeviceChangesServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockChangeService_ListDeviceChangesServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockChangeService_ListDeviceChangesServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockChangeService_ListDeviceChangesServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockChangeService_ListDeviceChangesServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type MockChangeService_ListNetworkChangesClient added in v0.6.11 

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

MockChangeService_ListNetworkChangesClient is a mock of ChangeService_ListNetworkChangesClient interface

func NewMockChangeService_ListNetworkChangesClient added in v0.6.11 

func NewMockChangeService_ListNetworkChangesClient(ctrl *gomock.Controller) *MockChangeService_ListNetworkChangesClient

NewMockChangeService_ListNetworkChangesClient creates a new mock instance

func (*MockChangeService_ListNetworkChangesClient) CloseSend added in v0.6.11 

func (m *MockChangeService_ListNetworkChangesClient) CloseSend() error

CloseSend mocks base method

func (*MockChangeService_ListNetworkChangesClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockChangeService_ListNetworkChangesClient) EXPECT added in v0.6.11 

func (m *MockChangeService_ListNetworkChangesClient) EXPECT() *MockChangeService_ListNetworkChangesClientMockRecorder

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

func (*MockChangeService_ListNetworkChangesClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockChangeService_ListNetworkChangesClient) Recv added in v0.6.11 

func (m *MockChangeService_ListNetworkChangesClient) Recv() (*ListNetworkChangeResponse, error)

Recv mocks base method

func (*MockChangeService_ListNetworkChangesClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockChangeService_ListNetworkChangesClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockChangeService_ListNetworkChangesClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockChangeService_ListNetworkChangesClientMockRecorder added in v0.6.11 

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

MockChangeService_ListNetworkChangesClientMockRecorder is the mock recorder for MockChangeService_ListNetworkChangesClient

func (*MockChangeService_ListNetworkChangesClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockChangeService_ListNetworkChangesClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockChangeService_ListNetworkChangesClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockChangeService_ListNetworkChangesClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockChangeService_ListNetworkChangesClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockChangeService_ListNetworkChangesClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockChangeService_ListNetworkChangesClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockChangeService_ListNetworkChangesServer added in v0.6.11 

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

MockChangeService_ListNetworkChangesServer is a mock of ChangeService_ListNetworkChangesServer interface

func NewMockChangeService_ListNetworkChangesServer added in v0.6.11 

func NewMockChangeService_ListNetworkChangesServer(ctrl *gomock.Controller) *MockChangeService_ListNetworkChangesServer

NewMockChangeService_ListNetworkChangesServer creates a new mock instance

func (*MockChangeService_ListNetworkChangesServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockChangeService_ListNetworkChangesServer) EXPECT added in v0.6.11 

func (m *MockChangeService_ListNetworkChangesServer) EXPECT() *MockChangeService_ListNetworkChangesServerMockRecorder

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

func (*MockChangeService_ListNetworkChangesServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockChangeService_ListNetworkChangesServer) Send added in v0.6.11 

func (m *MockChangeService_ListNetworkChangesServer) Send(arg0 *ListNetworkChangeResponse) error

Send mocks base method

func (*MockChangeService_ListNetworkChangesServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockChangeService_ListNetworkChangesServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockChangeService_ListNetworkChangesServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockChangeService_ListNetworkChangesServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockChangeService_ListNetworkChangesServerMockRecorder added in v0.6.11 

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

MockChangeService_ListNetworkChangesServerMockRecorder is the mock recorder for MockChangeService_ListNetworkChangesServer

func (*MockChangeService_ListNetworkChangesServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockChangeService_ListNetworkChangesServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockChangeService_ListNetworkChangesServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockChangeService_ListNetworkChangesServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockChangeService_ListNetworkChangesServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockChangeService_ListNetworkChangesServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockChangeService_ListNetworkChangesServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type MockOpStateDiagsClient added in v0.6.11 

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

MockOpStateDiagsClient is a mock of OpStateDiagsClient interface

func NewMockOpStateDiagsClient added in v0.6.11 

func NewMockOpStateDiagsClient(ctrl *gomock.Controller) *MockOpStateDiagsClient

NewMockOpStateDiagsClient creates a new mock instance

func (*MockOpStateDiagsClient) EXPECT added in v0.6.11 

func (m *MockOpStateDiagsClient) EXPECT() *MockOpStateDiagsClientMockRecorder

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

func (*MockOpStateDiagsClient) GetOpState added in v0.6.11 

func (m *MockOpStateDiagsClient) GetOpState(ctx context.Context, in *OpStateRequest, opts ...grpc.CallOption) (OpStateDiags_GetOpStateClient, error)

GetOpState mocks base method

type MockOpStateDiagsClientMockRecorder added in v0.6.11 

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

MockOpStateDiagsClientMockRecorder is the mock recorder for MockOpStateDiagsClient

func (*MockOpStateDiagsClientMockRecorder) GetOpState added in v0.6.11 

func (mr *MockOpStateDiagsClientMockRecorder) GetOpState(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetOpState indicates an expected call of GetOpState

type MockOpStateDiagsServer added in v0.6.11 

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

MockOpStateDiagsServer is a mock of OpStateDiagsServer interface

func NewMockOpStateDiagsServer added in v0.6.11 

func NewMockOpStateDiagsServer(ctrl *gomock.Controller) *MockOpStateDiagsServer

NewMockOpStateDiagsServer creates a new mock instance

func (*MockOpStateDiagsServer) EXPECT added in v0.6.11 

func (m *MockOpStateDiagsServer) EXPECT() *MockOpStateDiagsServerMockRecorder

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

func (*MockOpStateDiagsServer) GetOpState added in v0.6.11 

func (m *MockOpStateDiagsServer) GetOpState(arg0 *OpStateRequest, arg1 OpStateDiags_GetOpStateServer) error

GetOpState mocks base method

type MockOpStateDiagsServerMockRecorder added in v0.6.11 

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

MockOpStateDiagsServerMockRecorder is the mock recorder for MockOpStateDiagsServer

func (*MockOpStateDiagsServerMockRecorder) GetOpState added in v0.6.11 

func (mr *MockOpStateDiagsServerMockRecorder) GetOpState(arg0, arg1 interface{}) *gomock.Call

GetOpState indicates an expected call of GetOpState

type MockOpStateDiags_GetOpStateClient added in v0.6.11 

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

MockOpStateDiags_GetOpStateClient is a mock of OpStateDiags_GetOpStateClient interface

func NewMockOpStateDiags_GetOpStateClient added in v0.6.11 

func NewMockOpStateDiags_GetOpStateClient(ctrl *gomock.Controller) *MockOpStateDiags_GetOpStateClient

NewMockOpStateDiags_GetOpStateClient creates a new mock instance

func (*MockOpStateDiags_GetOpStateClient) CloseSend added in v0.6.11 

func (m *MockOpStateDiags_GetOpStateClient) CloseSend() error

CloseSend mocks base method

func (*MockOpStateDiags_GetOpStateClient) Context added in v0.6.11 

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

Context mocks base method

func (*MockOpStateDiags_GetOpStateClient) EXPECT added in v0.6.11 

func (m *MockOpStateDiags_GetOpStateClient) EXPECT() *MockOpStateDiags_GetOpStateClientMockRecorder

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

func (*MockOpStateDiags_GetOpStateClient) Header added in v0.6.11 

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

Header mocks base method

func (*MockOpStateDiags_GetOpStateClient) Recv added in v0.6.11 

func (m *MockOpStateDiags_GetOpStateClient) Recv() (*OpStateResponse, error)

Recv mocks base method

func (*MockOpStateDiags_GetOpStateClient) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockOpStateDiags_GetOpStateClient) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockOpStateDiags_GetOpStateClient) Trailer added in v0.6.11 

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

Trailer mocks base method

type MockOpStateDiags_GetOpStateClientMockRecorder added in v0.6.11 

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

MockOpStateDiags_GetOpStateClientMockRecorder is the mock recorder for MockOpStateDiags_GetOpStateClient

func (*MockOpStateDiags_GetOpStateClientMockRecorder) CloseSend added in v0.6.11 

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

CloseSend indicates an expected call of CloseSend

func (*MockOpStateDiags_GetOpStateClientMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockOpStateDiags_GetOpStateClientMockRecorder) Header added in v0.6.11 

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

Header indicates an expected call of Header

func (*MockOpStateDiags_GetOpStateClientMockRecorder) Recv added in v0.6.11 

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

Recv indicates an expected call of Recv

func (*MockOpStateDiags_GetOpStateClientMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockOpStateDiags_GetOpStateClientMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockOpStateDiags_GetOpStateClientMockRecorder) Trailer added in v0.6.11 

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

Trailer indicates an expected call of Trailer

type MockOpStateDiags_GetOpStateServer added in v0.6.11 

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

MockOpStateDiags_GetOpStateServer is a mock of OpStateDiags_GetOpStateServer interface

func NewMockOpStateDiags_GetOpStateServer added in v0.6.11 

func NewMockOpStateDiags_GetOpStateServer(ctrl *gomock.Controller) *MockOpStateDiags_GetOpStateServer

NewMockOpStateDiags_GetOpStateServer creates a new mock instance

func (*MockOpStateDiags_GetOpStateServer) Context added in v0.6.11 

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

Context mocks base method

func (*MockOpStateDiags_GetOpStateServer) EXPECT added in v0.6.11 

func (m *MockOpStateDiags_GetOpStateServer) EXPECT() *MockOpStateDiags_GetOpStateServerMockRecorder

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

func (*MockOpStateDiags_GetOpStateServer) RecvMsg added in v0.6.11 

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

RecvMsg mocks base method

func (*MockOpStateDiags_GetOpStateServer) Send added in v0.6.11 

func (m *MockOpStateDiags_GetOpStateServer) Send(arg0 *OpStateResponse) error

Send mocks base method

func (*MockOpStateDiags_GetOpStateServer) SendHeader added in v0.6.11 

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

SendHeader mocks base method

func (*MockOpStateDiags_GetOpStateServer) SendMsg added in v0.6.11 

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

SendMsg mocks base method

func (*MockOpStateDiags_GetOpStateServer) SetHeader added in v0.6.11 

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

SetHeader mocks base method

func (*MockOpStateDiags_GetOpStateServer) SetTrailer added in v0.6.11 

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

SetTrailer mocks base method

type MockOpStateDiags_GetOpStateServerMockRecorder added in v0.6.11 

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

MockOpStateDiags_GetOpStateServerMockRecorder is the mock recorder for MockOpStateDiags_GetOpStateServer

func (*MockOpStateDiags_GetOpStateServerMockRecorder) Context added in v0.6.11 

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

Context indicates an expected call of Context

func (*MockOpStateDiags_GetOpStateServerMockRecorder) RecvMsg added in v0.6.11 

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

RecvMsg indicates an expected call of RecvMsg

func (*MockOpStateDiags_GetOpStateServerMockRecorder) Send added in v0.6.11 

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

Send indicates an expected call of Send

func (*MockOpStateDiags_GetOpStateServerMockRecorder) SendHeader added in v0.6.11 

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

SendHeader indicates an expected call of SendHeader

func (*MockOpStateDiags_GetOpStateServerMockRecorder) SendMsg added in v0.6.11 

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

SendMsg indicates an expected call of SendMsg

func (*MockOpStateDiags_GetOpStateServerMockRecorder) SetHeader added in v0.6.11 

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

SetHeader indicates an expected call of SetHeader

func (*MockOpStateDiags_GetOpStateServerMockRecorder) SetTrailer added in v0.6.11 

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

SetTrailer indicates an expected call of SetTrailer

type OpStateDiagsClient 

type OpStateDiagsClient interface {
	// GetOpState returns a stream of submitted OperationalStateCache aimed at individual devices.
	// If subscribe is true keep on streaming after the initial set are finished
	GetOpState(ctx context.Context, in *OpStateRequest, opts ...grpc.CallOption) (OpStateDiags_GetOpStateClient, error)
}

OpStateDiagsClient is the client API for OpStateDiags service.

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

func CreateOpStateDiagsClient 

func CreateOpStateDiagsClient(cc *grpc.ClientConn) OpStateDiagsClient

CreateOpStateDiagsClient creates and returns a new op state diags client

func NewOpStateDiagsClient 

func NewOpStateDiagsClient(cc *grpc.ClientConn) OpStateDiagsClient

type OpStateDiagsServer 

type OpStateDiagsServer interface {
	// GetOpState returns a stream of submitted OperationalStateCache aimed at individual devices.
	// If subscribe is true keep on streaming after the initial set are finished
	GetOpState(*OpStateRequest, OpStateDiags_GetOpStateServer) error
}

OpStateDiagsServer is the server API for OpStateDiags service.

type OpStateDiags_GetOpStateClient 

type OpStateDiags_GetOpStateClient interface {
	Recv() (*OpStateResponse, error)
	grpc.ClientStream
}

type OpStateDiags_GetOpStateServer 

type OpStateDiags_GetOpStateServer interface {
	Send(*OpStateResponse) error
	grpc.ServerStream
}

type OpStateRequest 

type OpStateRequest struct {
	// The request is always in the context of a Device ID. If the device does
	// not exist or is disconnected an error will be returned.
	DeviceId string `protobuf:"bytes,1,opt,name=deviceId,proto3" json:"deviceId,omitempty"`
	// subscribe indicates whether to subscribe to events (e.g. ADD, UPDATE, and REMOVE) that occur
	// after all paths for the device have been streamed to the client
	Subscribe bool `protobuf:"varint,2,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
}

OpStateRequest is a message for specifying GetOpState query parameters.

func (*OpStateRequest) Descriptor 

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

func (*OpStateRequest) GetDeviceId 

func (m *OpStateRequest) GetDeviceId() string

func (*OpStateRequest) GetSubscribe 

func (m *OpStateRequest) GetSubscribe() bool

func (*OpStateRequest) Marshal 

func (m *OpStateRequest) Marshal() (dAtA []byte, err error)

func (*OpStateRequest) MarshalTo 

func (m *OpStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*OpStateRequest) MarshalToSizedBuffer 

func (m *OpStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OpStateRequest) ProtoMessage 

func (*OpStateRequest) ProtoMessage()

func (*OpStateRequest) Reset 

func (m *OpStateRequest) Reset()

func (*OpStateRequest) Size 

func (m *OpStateRequest) Size() (n int)

func (*OpStateRequest) String 

func (m *OpStateRequest) String() string

func (*OpStateRequest) Unmarshal 

func (m *OpStateRequest) Unmarshal(dAtA []byte) error

func (*OpStateRequest) XXX_DiscardUnknown 

func (m *OpStateRequest) XXX_DiscardUnknown()

func (*OpStateRequest) XXX_Marshal 

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

func (*OpStateRequest) XXX_Merge 

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

func (*OpStateRequest) XXX_Size 

func (m *OpStateRequest) XXX_Size() int

func (*OpStateRequest) XXX_Unmarshal 

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

type OpStateResponse 

type OpStateResponse struct {
	// type is the type of the event
	Type admin.Type `protobuf:"varint,1,opt,name=type,proto3,enum=onos.config.admin.Type" json:"type,omitempty"`
	// device is the device on which the event occurred
	Pathvalue *device.PathValue `protobuf:"bytes,2,opt,name=pathvalue,proto3" json:"pathvalue,omitempty"`
}

func (*OpStateResponse) Descriptor 

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

func (*OpStateResponse) GetPathvalue 

func (m *OpStateResponse) GetPathvalue() *device.PathValue

func (*OpStateResponse) GetType 

func (m *OpStateResponse) GetType() admin.Type

func (*OpStateResponse) Marshal 

func (m *OpStateResponse) Marshal() (dAtA []byte, err error)

func (*OpStateResponse) MarshalTo 

func (m *OpStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*OpStateResponse) MarshalToSizedBuffer 

func (m *OpStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OpStateResponse) ProtoMessage 

func (*OpStateResponse) ProtoMessage()

func (*OpStateResponse) Reset 

func (m *OpStateResponse) Reset()

func (*OpStateResponse) Size 

func (m *OpStateResponse) Size() (n int)

func (*OpStateResponse) String 

func (m *OpStateResponse) String() string

func (*OpStateResponse) Unmarshal 

func (m *OpStateResponse) Unmarshal(dAtA []byte) error

func (*OpStateResponse) XXX_DiscardUnknown 

func (m *OpStateResponse) XXX_DiscardUnknown()

func (*OpStateResponse) XXX_Marshal 

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

func (*OpStateResponse) XXX_Merge 

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

func (*OpStateResponse) XXX_Size 

func (m *OpStateResponse) XXX_Size() int

func (*OpStateResponse) XXX_Unmarshal 

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

type Type 

type Type int32

Change (Network or Device) event type 

const (
	// NONE indicates this response does not represent a modification of the Change
	Type_NONE Type = 0
	// ADDED is an event which occurs when a Change is added to the topology
	Type_ADDED Type = 1
	// UPDATED is an event which occurs when a Change is updated
	Type_UPDATED Type = 2
	// REMOVED is an event which occurs when a Change is removed from the configuration
	Type_REMOVED Type = 3
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

type UnimplementedChangeServiceServer 

type UnimplementedChangeServiceServer struct {
}

UnimplementedChangeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedChangeServiceServer) ListDeviceChanges 

func (*UnimplementedChangeServiceServer) ListDeviceChanges(req *ListDeviceChangeRequest, srv ChangeService_ListDeviceChangesServer) error

func (*UnimplementedChangeServiceServer) ListNetworkChanges 

func (*UnimplementedChangeServiceServer) ListNetworkChanges(req *ListNetworkChangeRequest, srv ChangeService_ListNetworkChangesServer) error

type UnimplementedOpStateDiagsServer 

type UnimplementedOpStateDiagsServer struct {
}

UnimplementedOpStateDiagsServer can be embedded to have forward compatible implementations.

func (*UnimplementedOpStateDiagsServer) GetOpState 

func (*UnimplementedOpStateDiagsServer) GetOpState(req *OpStateRequest, srv OpStateDiags_GetOpStateServer) 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.