metadata

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Feb 6, 2017 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MetadataExposable

type MetadataExposable struct {
	mock.Mock
}

MetadataExposable is an autogenerated mock type for the MetadataExposable type

func (*MetadataExposable) HostAddrToUUID

func (_m *MetadataExposable) HostAddrToUUID(hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: hostAddr

func (*MetadataExposable) ListExtentsStats

ListExtentsStats provides a mock function with given fields: request

func (*MetadataExposable) ListHosts

ListHosts provides a mock function with given fields: request

func (*MetadataExposable) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: request

func (*MetadataExposable) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: request

func (*MetadataExposable) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: request

func (*MetadataExposable) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: request

func (*MetadataExposable) ReadExtentStats

ReadExtentStats provides a mock function with given fields: request

func (*MetadataExposable) UUIDToHostAddr

func (_m *MetadataExposable) UUIDToHostAddr(hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: hostUUID

type MetadataService

type MetadataService struct {
	mock.Mock
}

MetadataService is an autogenerated mock type for the MetadataService type

func (*MetadataService) CreateConsumerGroup

func (_m *MetadataService) CreateConsumerGroup(registerRequest *shared.CreateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

CreateConsumerGroup provides a mock function with given fields: registerRequest

func (*MetadataService) CreateConsumerGroupExtent

func (_m *MetadataService) CreateConsumerGroupExtent(request *metadata.CreateConsumerGroupExtentRequest) error

CreateConsumerGroupExtent provides a mock function with given fields: request

func (*MetadataService) CreateDestination

func (_m *MetadataService) CreateDestination(createRequest *shared.CreateDestinationRequest) (*shared.DestinationDescription, error)

CreateDestination provides a mock function with given fields: createRequest

func (*MetadataService) CreateExtent

CreateExtent provides a mock function with given fields: request

func (*MetadataService) DeleteConsumerGroup

func (_m *MetadataService) DeleteConsumerGroup(deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteConsumerGroup provides a mock function with given fields: deleteRequest

func (*MetadataService) DeleteDestination

func (_m *MetadataService) DeleteDestination(deleteRequest *shared.DeleteDestinationRequest) error

DeleteDestination provides a mock function with given fields: deleteRequest

func (*MetadataService) DeleteDestinationUUID

func (_m *MetadataService) DeleteDestinationUUID(deleteRequest *metadata.DeleteDestinationUUIDRequest) error

DeleteDestinationUUID provides a mock function with given fields: deleteRequest

func (*MetadataService) HostAddrToUUID

func (_m *MetadataService) HostAddrToUUID(hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: hostAddr

func (*MetadataService) ListConsumerGroups

ListConsumerGroups provides a mock function with given fields: listRequest

func (*MetadataService) ListDestinations

func (_m *MetadataService) ListDestinations(listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

ListDestinations provides a mock function with given fields: listRequest

func (*MetadataService) ListDestinationsByUUID

func (_m *MetadataService) ListDestinationsByUUID(listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)

ListDestinationsByUUID provides a mock function with given fields: listRequest

func (*MetadataService) ListExtentsStats

ListExtentsStats provides a mock function with given fields: request

func (*MetadataService) ListHosts

ListHosts provides a mock function with given fields: request

func (*MetadataService) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: request

func (*MetadataService) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: request

func (*MetadataService) MoveExtent

func (_m *MetadataService) MoveExtent(request *metadata.MoveExtentRequest) error

MoveExtent provides a mock function with given fields: request

func (*MetadataService) ReadConsumerGroup

ReadConsumerGroup provides a mock function with given fields: getRequest

func (*MetadataService) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: request

func (*MetadataService) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: request

func (*MetadataService) ReadDestination

ReadDestination provides a mock function with given fields: getRequest

func (*MetadataService) ReadExtentStats

ReadExtentStats provides a mock function with given fields: request

func (*MetadataService) ReadStoreExtentReplicaStats

ReadStoreExtentReplicaStats provides a mock function with given fields: request

func (*MetadataService) RegisterHostUUID

func (_m *MetadataService) RegisterHostUUID(request *metadata.RegisterHostUUIDRequest) error

RegisterHostUUID provides a mock function with given fields: request

func (*MetadataService) SealExtent

func (_m *MetadataService) SealExtent(request *metadata.SealExtentRequest) error

SealExtent provides a mock function with given fields: request

func (*MetadataService) SetAckOffset

func (_m *MetadataService) SetAckOffset(request *metadata.SetAckOffsetRequest) error

SetAckOffset provides a mock function with given fields: request

func (*MetadataService) SetOutputHost

func (_m *MetadataService) SetOutputHost(request *metadata.SetOutputHostRequest) error

SetOutputHost provides a mock function with given fields: request

func (*MetadataService) UUIDToHostAddr

func (_m *MetadataService) UUIDToHostAddr(hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: hostUUID

func (*MetadataService) UpdateConsumerGroup

func (_m *MetadataService) UpdateConsumerGroup(updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

UpdateConsumerGroup provides a mock function with given fields: updateRequest

func (*MetadataService) UpdateConsumerGroupExtentStatus

func (_m *MetadataService) UpdateConsumerGroupExtentStatus(request *metadata.UpdateConsumerGroupExtentStatusRequest) error

UpdateConsumerGroupExtentStatus provides a mock function with given fields: request

func (*MetadataService) UpdateDestination

func (_m *MetadataService) UpdateDestination(updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)

UpdateDestination provides a mock function with given fields: updateRequest

func (*MetadataService) UpdateDestinationDLQCursors

func (_m *MetadataService) UpdateDestinationDLQCursors(updateRequest *metadata.UpdateDestinationDLQCursorsRequest) (*shared.DestinationDescription, error)

UpdateDestinationDLQCursors provides a mock function with given fields: updateRequest

func (*MetadataService) UpdateExtentReplicaStats

func (_m *MetadataService) UpdateExtentReplicaStats(request *metadata.UpdateExtentReplicaStatsRequest) error

UpdateExtentReplicaStats provides a mock function with given fields: request

func (*MetadataService) UpdateExtentStats

UpdateExtentStats provides a mock function with given fields: request

func (*MetadataService) UpdateStoreExtentReplicaStats

func (_m *MetadataService) UpdateStoreExtentReplicaStats(request *metadata.UpdateStoreExtentReplicaStatsRequest) error

UpdateStoreExtentReplicaStats provides a mock function with given fields: request

type MetadataServiceListConsumerGroupsInCall

type MetadataServiceListConsumerGroupsInCall struct {
	mock.Mock
}

MetadataServiceListConsumerGroupsInCall is an autogenerated mock type for the MetadataServiceListConsumerGroupsInCall type

func (*MetadataServiceListConsumerGroupsInCall) Done

Done provides a mock function with given fields:

func (*MetadataServiceListConsumerGroupsInCall) Flush

Flush provides a mock function with given fields:

func (*MetadataServiceListConsumerGroupsInCall) SetResponseHeaders

func (_m *MetadataServiceListConsumerGroupsInCall) SetResponseHeaders(headers map[string]string) error

SetResponseHeaders provides a mock function with given fields: headers

func (*MetadataServiceListConsumerGroupsInCall) Write

Write provides a mock function with given fields: arg

type MetadataServiceListConsumerGroupsOutCall

type MetadataServiceListConsumerGroupsOutCall struct {
	mock.Mock
}

MetadataServiceListConsumerGroupsOutCall is an autogenerated mock type for the MetadataServiceListConsumerGroupsOutCall type

func (*MetadataServiceListConsumerGroupsOutCall) Read

Read provides a mock function with given fields:

func (*MetadataServiceListConsumerGroupsOutCall) ResponseHeaders

func (_m *MetadataServiceListConsumerGroupsOutCall) ResponseHeaders() (map[string]string, error)

ResponseHeaders provides a mock function with given fields:

type MetadataServiceListDestinationsByUUIDInCall

type MetadataServiceListDestinationsByUUIDInCall struct {
	mock.Mock
}

MetadataServiceListDestinationsByUUIDInCall is an autogenerated mock type for the MetadataServiceListDestinationsByUUIDInCall type

func (*MetadataServiceListDestinationsByUUIDInCall) Done

Done provides a mock function with given fields:

func (*MetadataServiceListDestinationsByUUIDInCall) Flush

Flush provides a mock function with given fields:

func (*MetadataServiceListDestinationsByUUIDInCall) SetResponseHeaders

func (_m *MetadataServiceListDestinationsByUUIDInCall) SetResponseHeaders(headers map[string]string) error

SetResponseHeaders provides a mock function with given fields: headers

func (*MetadataServiceListDestinationsByUUIDInCall) Write

Write provides a mock function with given fields: arg

type MetadataServiceListDestinationsByUUIDOutCall

type MetadataServiceListDestinationsByUUIDOutCall struct {
	mock.Mock
}

MetadataServiceListDestinationsByUUIDOutCall is an autogenerated mock type for the MetadataServiceListDestinationsByUUIDOutCall type

func (*MetadataServiceListDestinationsByUUIDOutCall) Read

Read provides a mock function with given fields:

func (*MetadataServiceListDestinationsByUUIDOutCall) ResponseHeaders

func (_m *MetadataServiceListDestinationsByUUIDOutCall) ResponseHeaders() (map[string]string, error)

ResponseHeaders provides a mock function with given fields:

type MetadataServiceListDestinationsInCall

type MetadataServiceListDestinationsInCall struct {
	mock.Mock
}

MetadataServiceListDestinationsInCall is an autogenerated mock type for the MetadataServiceListDestinationsInCall type

func (*MetadataServiceListDestinationsInCall) Done

Done provides a mock function with given fields:

func (*MetadataServiceListDestinationsInCall) Flush

Flush provides a mock function with given fields:

func (*MetadataServiceListDestinationsInCall) SetResponseHeaders

func (_m *MetadataServiceListDestinationsInCall) SetResponseHeaders(headers map[string]string) error

SetResponseHeaders provides a mock function with given fields: headers

func (*MetadataServiceListDestinationsInCall) Write

Write provides a mock function with given fields: arg

type MetadataServiceListDestinationsOutCall

type MetadataServiceListDestinationsOutCall struct {
	mock.Mock
}

MetadataServiceListDestinationsOutCall is an autogenerated mock type for the MetadataServiceListDestinationsOutCall type

func (*MetadataServiceListDestinationsOutCall) Read

Read provides a mock function with given fields:

func (*MetadataServiceListDestinationsOutCall) ResponseHeaders

func (_m *MetadataServiceListDestinationsOutCall) ResponseHeaders() (map[string]string, error)

ResponseHeaders provides a mock function with given fields:

type MetadataServiceListExtentsStatsStreamInCall

type MetadataServiceListExtentsStatsStreamInCall struct {
	mock.Mock
}

MetadataServiceListExtentsStatsStreamInCall is an autogenerated mock type for the MetadataServiceListExtentsStatsStreamInCall type

func (*MetadataServiceListExtentsStatsStreamInCall) Done

Done provides a mock function with given fields:

func (*MetadataServiceListExtentsStatsStreamInCall) Flush

Flush provides a mock function with given fields:

func (*MetadataServiceListExtentsStatsStreamInCall) SetResponseHeaders

func (_m *MetadataServiceListExtentsStatsStreamInCall) SetResponseHeaders(headers map[string]string) error

SetResponseHeaders provides a mock function with given fields: headers

func (*MetadataServiceListExtentsStatsStreamInCall) Write

Write provides a mock function with given fields: arg

type MetadataServiceListExtentsStatsStreamOutCall

type MetadataServiceListExtentsStatsStreamOutCall struct {
	mock.Mock
}

MetadataServiceListExtentsStatsStreamOutCall is an autogenerated mock type for the MetadataServiceListExtentsStatsStreamOutCall type

func (*MetadataServiceListExtentsStatsStreamOutCall) Read

Read provides a mock function with given fields:

func (*MetadataServiceListExtentsStatsStreamOutCall) ResponseHeaders

func (_m *MetadataServiceListExtentsStatsStreamOutCall) ResponseHeaders() (map[string]string, error)

ResponseHeaders provides a mock function with given fields:

type MetadataServiceReadConsumerGroupExtentsStreamInCall

type MetadataServiceReadConsumerGroupExtentsStreamInCall struct {
	mock.Mock
}

MetadataServiceReadConsumerGroupExtentsStreamInCall is an autogenerated mock type for the MetadataServiceReadConsumerGroupExtentsStreamInCall type

func (*MetadataServiceReadConsumerGroupExtentsStreamInCall) Done

Done provides a mock function with given fields:

func (*MetadataServiceReadConsumerGroupExtentsStreamInCall) Flush

Flush provides a mock function with given fields:

func (*MetadataServiceReadConsumerGroupExtentsStreamInCall) SetResponseHeaders

func (_m *MetadataServiceReadConsumerGroupExtentsStreamInCall) SetResponseHeaders(headers map[string]string) error

SetResponseHeaders provides a mock function with given fields: headers

func (*MetadataServiceReadConsumerGroupExtentsStreamInCall) Write

Write provides a mock function with given fields: arg

type MetadataServiceReadConsumerGroupExtentsStreamOutCall

type MetadataServiceReadConsumerGroupExtentsStreamOutCall struct {
	mock.Mock
}

MetadataServiceReadConsumerGroupExtentsStreamOutCall is an autogenerated mock type for the MetadataServiceReadConsumerGroupExtentsStreamOutCall type

func (*MetadataServiceReadConsumerGroupExtentsStreamOutCall) Read

Read provides a mock function with given fields:

func (*MetadataServiceReadConsumerGroupExtentsStreamOutCall) ResponseHeaders

ResponseHeaders provides a mock function with given fields:

type TChanMetadataExposable

type TChanMetadataExposable struct {
	mock.Mock
}

TChanMetadataExposable is an autogenerated mock type for the TChanMetadataExposable type

func (*TChanMetadataExposable) CreateServiceConfig added in v0.2.0

func (_m *TChanMetadataExposable) CreateServiceConfig(ctx thrift.Context, request *metadata.CreateServiceConfigRequest) error

CreateServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) DeleteServiceConfig added in v0.2.0

func (_m *TChanMetadataExposable) DeleteServiceConfig(ctx thrift.Context, request *metadata.DeleteServiceConfigRequest) error

DeleteServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) HostAddrToUUID

func (_m *TChanMetadataExposable) HostAddrToUUID(ctx thrift.Context, hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: ctx, hostAddr

func (*TChanMetadataExposable) ListAllConsumerGroups added in v0.2.0

ListAllConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataExposable) ListConsumerGroups added in v0.2.0

ListConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataExposable) ListDestinations added in v0.2.0

ListDestinations provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataExposable) ListDestinationsByUUID added in v0.2.0

ListDestinationsByUUID provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataExposable) ListEntityOps added in v0.2.0

ListEntityOps provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataExposable) ListExtentsStats

ListExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ListHosts

ListHosts provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ReadConsumerGroup added in v0.2.0

ReadConsumerGroup provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataExposable) ReadConsumerGroupByUUID added in v0.2.0

ReadConsumerGroupByUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ReadConsumerGroupExtentsByExtUUID added in v0.2.0

ReadConsumerGroupExtentsByExtUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ReadDestination added in v0.2.0

ReadDestination provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataExposable) ReadExtentStats

ReadExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) ReadServiceConfig added in v0.2.0

ReadServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataExposable) UUIDToHostAddr

func (_m *TChanMetadataExposable) UUIDToHostAddr(ctx thrift.Context, hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: ctx, hostUUID

func (*TChanMetadataExposable) UpdateServiceConfig added in v0.2.0

func (_m *TChanMetadataExposable) UpdateServiceConfig(ctx thrift.Context, request *metadata.UpdateServiceConfigRequest) error

UpdateServiceConfig provides a mock function with given fields: ctx, request

type TChanMetadataExposableClient

type TChanMetadataExposableClient struct {
	mock.Mock
}

TChanMetadataExposableClient is an autogenerated mock type for the TChanMetadataExposableClient type

func (*TChanMetadataExposableClient) HostAddrToUUID

func (_m *TChanMetadataExposableClient) HostAddrToUUID(ctx thrift.Context, hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: ctx, hostAddr

func (*TChanMetadataExposableClient) ListExtentsStats

ListExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) ListHosts

ListHosts provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) ReadExtentStats

ReadExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableClient) UUIDToHostAddr

func (_m *TChanMetadataExposableClient) UUIDToHostAddr(ctx thrift.Context, hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: ctx, hostUUID

type TChanMetadataExposableServer

type TChanMetadataExposableServer struct {
	mock.Mock
}

TChanMetadataExposableServer is an autogenerated mock type for the TChanMetadataExposableServer type

func (*TChanMetadataExposableServer) HostAddrToUUID

func (_m *TChanMetadataExposableServer) HostAddrToUUID(ctx thrift.Context, hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: ctx, hostAddr

func (*TChanMetadataExposableServer) ListExtentsStats

ListExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) ListHosts

ListHosts provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) ReadExtentStats

ReadExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataExposableServer) UUIDToHostAddr

func (_m *TChanMetadataExposableServer) UUIDToHostAddr(ctx thrift.Context, hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: ctx, hostUUID

type TChanMetadataService

type TChanMetadataService struct {
	mock.Mock
}

TChanMetadataService is an autogenerated mock type for the TChanMetadataService type

func (*TChanMetadataService) CreateConsumerGroup

CreateConsumerGroup provides a mock function with given fields: ctx, createRequest

func (*TChanMetadataService) CreateConsumerGroupExtent

func (_m *TChanMetadataService) CreateConsumerGroupExtent(ctx thrift.Context, request *metadata.CreateConsumerGroupExtentRequest) error

CreateConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataService) CreateDestination

CreateDestination provides a mock function with given fields: ctx, createRequest

func (*TChanMetadataService) CreateDestinationUUID

func (_m *TChanMetadataService) CreateDestinationUUID(ctx thrift.Context, createRequest *shared.CreateDestinationUUIDRequest) (*shared.DestinationDescription, error)

CreateDestinationUUID provides a mock function with given fields: ctx, createRequest

func (*TChanMetadataService) CreateExtent

CreateExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataService) CreateHostInfo

func (_m *TChanMetadataService) CreateHostInfo(ctx thrift.Context, request *metadata.CreateHostInfoRequest) error

CreateHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataService) CreateServiceConfig

func (_m *TChanMetadataService) CreateServiceConfig(ctx thrift.Context, request *metadata.CreateServiceConfigRequest) error

CreateServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataService) DeleteConsumerGroup

func (_m *TChanMetadataService) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteConsumerGroup provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataService) DeleteDestination

func (_m *TChanMetadataService) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error

DeleteDestination provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataService) DeleteDestinationUUID

func (_m *TChanMetadataService) DeleteDestinationUUID(ctx thrift.Context, deleteRequest *metadata.DeleteDestinationUUIDRequest) error

DeleteDestinationUUID provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataService) DeleteHostInfo

func (_m *TChanMetadataService) DeleteHostInfo(ctx thrift.Context, request *metadata.DeleteHostInfoRequest) error

DeleteHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataService) DeleteServiceConfig

func (_m *TChanMetadataService) DeleteServiceConfig(ctx thrift.Context, request *metadata.DeleteServiceConfigRequest) error

DeleteServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataService) HostAddrToUUID

func (_m *TChanMetadataService) HostAddrToUUID(ctx thrift.Context, hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: ctx, hostAddr

func (*TChanMetadataService) ListAllConsumerGroups

ListAllConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataService) ListConsumerGroups

ListConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataService) ListDestinationExtents added in v0.2.0

ListDestinationExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ListDestinations

ListDestinations provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataService) ListDestinationsByUUID

ListDestinationsByUUID provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataService) ListEntityOps

ListEntityOps provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataService) ListExtentsStats

ListExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ListHosts

ListHosts provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) MoveExtent

func (_m *TChanMetadataService) MoveExtent(ctx thrift.Context, request *metadata.MoveExtentRequest) error

MoveExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadConsumerGroup

ReadConsumerGroup provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataService) ReadConsumerGroupByUUID

ReadConsumerGroupByUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadConsumerGroupExtentsByExtUUID

ReadConsumerGroupExtentsByExtUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadConsumerGroupExtentsLite added in v0.2.0

ReadConsumerGroupExtentsLite provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadDestination

ReadDestination provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataService) ReadExtentStats

ReadExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadHostInfo

ReadHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadServiceConfig

ReadServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataService) ReadStoreExtentReplicaStats

ReadStoreExtentReplicaStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) RegisterHostUUID

func (_m *TChanMetadataService) RegisterHostUUID(ctx thrift.Context, request *metadata.RegisterHostUUIDRequest) error

RegisterHostUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataService) SealExtent

func (_m *TChanMetadataService) SealExtent(ctx thrift.Context, request *metadata.SealExtentRequest) error

SealExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataService) SetAckOffset

func (_m *TChanMetadataService) SetAckOffset(ctx thrift.Context, request *metadata.SetAckOffsetRequest) error

SetAckOffset provides a mock function with given fields: ctx, request

func (*TChanMetadataService) SetOutputHost

func (_m *TChanMetadataService) SetOutputHost(ctx thrift.Context, request *metadata.SetOutputHostRequest) error

SetOutputHost provides a mock function with given fields: ctx, request

func (*TChanMetadataService) UUIDToHostAddr

func (_m *TChanMetadataService) UUIDToHostAddr(ctx thrift.Context, hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: ctx, hostUUID

func (*TChanMetadataService) UpdateConsumerGroup

UpdateConsumerGroup provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataService) UpdateConsumerGroupExtentStatus

func (_m *TChanMetadataService) UpdateConsumerGroupExtentStatus(ctx thrift.Context, request *metadata.UpdateConsumerGroupExtentStatusRequest) error

UpdateConsumerGroupExtentStatus provides a mock function with given fields: ctx, request

func (*TChanMetadataService) UpdateDestination

UpdateDestination provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataService) UpdateDestinationDLQCursors

func (_m *TChanMetadataService) UpdateDestinationDLQCursors(ctx thrift.Context, updateRequest *metadata.UpdateDestinationDLQCursorsRequest) (*shared.DestinationDescription, error)

UpdateDestinationDLQCursors provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataService) UpdateExtentReplicaStats

func (_m *TChanMetadataService) UpdateExtentReplicaStats(ctx thrift.Context, request *metadata.UpdateExtentReplicaStatsRequest) error

UpdateExtentReplicaStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) UpdateExtentStats

UpdateExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataService) UpdateHostInfo

func (_m *TChanMetadataService) UpdateHostInfo(ctx thrift.Context, request *metadata.UpdateHostInfoRequest) error

UpdateHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataService) UpdateServiceConfig

func (_m *TChanMetadataService) UpdateServiceConfig(ctx thrift.Context, request *metadata.UpdateServiceConfigRequest) error

UpdateServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataService) UpdateStoreExtentReplicaStats

func (_m *TChanMetadataService) UpdateStoreExtentReplicaStats(ctx thrift.Context, request *metadata.UpdateStoreExtentReplicaStatsRequest) error

UpdateStoreExtentReplicaStats provides a mock function with given fields: ctx, request

type TChanMetadataServiceClient

type TChanMetadataServiceClient struct {
	mock.Mock
}

TChanMetadataServiceClient is an autogenerated mock type for the TChanMetadataServiceClient type

func (*TChanMetadataServiceClient) CreateConsumerGroup

CreateConsumerGroup provides a mock function with given fields: ctx, registerRequest

func (*TChanMetadataServiceClient) CreateConsumerGroupExtent

func (_m *TChanMetadataServiceClient) CreateConsumerGroupExtent(ctx thrift.Context, request *metadata.CreateConsumerGroupExtentRequest) error

CreateConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) CreateDestination

CreateDestination provides a mock function with given fields: ctx, createRequest

func (*TChanMetadataServiceClient) CreateDestinationUUID

CreateDestinationUUID provides a mock function with given fields: ctx, createRequest

func (*TChanMetadataServiceClient) CreateExtent

CreateExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) CreateHostInfo

CreateHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) CreateServiceConfig

func (_m *TChanMetadataServiceClient) CreateServiceConfig(ctx thrift.Context, request *metadata.CreateServiceConfigRequest) error

CreateServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) DeleteConsumerGroup

func (_m *TChanMetadataServiceClient) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteConsumerGroup provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataServiceClient) DeleteDestination

func (_m *TChanMetadataServiceClient) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error

DeleteDestination provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataServiceClient) DeleteDestinationUUID

func (_m *TChanMetadataServiceClient) DeleteDestinationUUID(ctx thrift.Context, deleteRequest *metadata.DeleteDestinationUUIDRequest) error

DeleteDestinationUUID provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataServiceClient) DeleteHostInfo

DeleteHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) DeleteServiceConfig

func (_m *TChanMetadataServiceClient) DeleteServiceConfig(ctx thrift.Context, request *metadata.DeleteServiceConfigRequest) error

DeleteServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) HostAddrToUUID

func (_m *TChanMetadataServiceClient) HostAddrToUUID(ctx thrift.Context, hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: ctx, hostAddr

func (*TChanMetadataServiceClient) ListAllConsumerGroups

ListAllConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceClient) ListConsumerGroups

ListConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceClient) ListDestinationExtents added in v0.2.0

ListDestinationExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ListDestinations

ListDestinations provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceClient) ListDestinationsByUUID

ListDestinationsByUUID provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceClient) ListEntityOps

ListAllConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceClient) ListExtentsStats

ListExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ListHosts

ListHosts provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) MoveExtent

MoveExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadConsumerGroup

ReadConsumerGroup provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataServiceClient) ReadConsumerGroupByUUID

ReadConsumerGroupByUUID provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataServiceClient) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadConsumerGroupExtentsByExtUUID

ReadConsumerGroupExtentsByExtUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadConsumerGroupExtentsLite added in v0.2.0

ReadConsumerGroupExtentsLite provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadDestination

ReadDestination provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataServiceClient) ReadExtentStats

ReadExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadHostInfo

ReadHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadServiceConfig

ReadServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) ReadStoreExtentReplicaStats

ReadStoreExtentReplicaStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) RegisterHostUUID

func (_m *TChanMetadataServiceClient) RegisterHostUUID(ctx thrift.Context, request *metadata.RegisterHostUUIDRequest) error

RegisterHostUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) SealExtent

SealExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) SetAckOffset

SetAckOffset provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) SetOutputHost

SetOutputHost provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) UUIDToHostAddr

func (_m *TChanMetadataServiceClient) UUIDToHostAddr(ctx thrift.Context, hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: ctx, hostUUID

func (*TChanMetadataServiceClient) UpdateConsumerGroup

UpdateConsumerGroup provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataServiceClient) UpdateConsumerGroupExtentStatus

func (_m *TChanMetadataServiceClient) UpdateConsumerGroupExtentStatus(ctx thrift.Context, request *metadata.UpdateConsumerGroupExtentStatusRequest) error

UpdateConsumerGroupExtentStatus provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) UpdateDestination

UpdateDestination provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataServiceClient) UpdateDestinationDLQCursors

UpdateDestinationDLQCursors provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataServiceClient) UpdateExtentReplicaStats

func (_m *TChanMetadataServiceClient) UpdateExtentReplicaStats(ctx thrift.Context, request *metadata.UpdateExtentReplicaStatsRequest) error

UpdateExtentReplicaStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) UpdateExtentStats

UpdateExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) UpdateHostInfo

UpdateHostInfo provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) UpdateServiceConfig

func (_m *TChanMetadataServiceClient) UpdateServiceConfig(ctx thrift.Context, request *metadata.UpdateServiceConfigRequest) error

UpdateServiceConfig provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceClient) UpdateStoreExtentReplicaStats

func (_m *TChanMetadataServiceClient) UpdateStoreExtentReplicaStats(ctx thrift.Context, request *metadata.UpdateStoreExtentReplicaStatsRequest) error

UpdateStoreExtentReplicaStats provides a mock function with given fields: ctx, request

type TChanMetadataServiceServer

type TChanMetadataServiceServer struct {
	mock.Mock
}

TChanMetadataServiceServer is an autogenerated mock type for the TChanMetadataServiceServer type

func (*TChanMetadataServiceServer) CreateConsumerGroup

CreateConsumerGroup provides a mock function with given fields: ctx, registerRequest

func (*TChanMetadataServiceServer) CreateConsumerGroupExtent

func (_m *TChanMetadataServiceServer) CreateConsumerGroupExtent(ctx thrift.Context, request *metadata.CreateConsumerGroupExtentRequest) error

CreateConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) CreateDestination

CreateDestination provides a mock function with given fields: ctx, createRequest

func (*TChanMetadataServiceServer) CreateExtent

CreateExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) DeleteConsumerGroup

func (_m *TChanMetadataServiceServer) DeleteConsumerGroup(ctx thrift.Context, deleteRequest *shared.DeleteConsumerGroupRequest) error

DeleteConsumerGroup provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataServiceServer) DeleteDestination

func (_m *TChanMetadataServiceServer) DeleteDestination(ctx thrift.Context, deleteRequest *shared.DeleteDestinationRequest) error

DeleteDestination provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataServiceServer) DeleteDestinationUUID

func (_m *TChanMetadataServiceServer) DeleteDestinationUUID(ctx thrift.Context, deleteRequest *metadata.DeleteDestinationUUIDRequest) error

DeleteDestinationUUID provides a mock function with given fields: ctx, deleteRequest

func (*TChanMetadataServiceServer) HostAddrToUUID

func (_m *TChanMetadataServiceServer) HostAddrToUUID(ctx thrift.Context, hostAddr string) (string, error)

HostAddrToUUID provides a mock function with given fields: ctx, hostAddr

func (*TChanMetadataServiceServer) ListConsumerGroups

ListConsumerGroups provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceServer) ListDestinations

ListDestinations provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceServer) ListDestinationsByUUID

ListDestinationsByUUID provides a mock function with given fields: ctx, listRequest

func (*TChanMetadataServiceServer) ListExtentsStats

ListExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ListHosts

ListHosts provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ListInputHostExtentsStats

ListInputHostExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ListStoreExtentsStats

ListStoreExtentsStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) MoveExtent

MoveExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ReadConsumerGroup

ReadConsumerGroup provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataServiceServer) ReadConsumerGroupExtent

ReadConsumerGroupExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ReadConsumerGroupExtents

ReadConsumerGroupExtents provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ReadDestination

ReadDestination provides a mock function with given fields: ctx, getRequest

func (*TChanMetadataServiceServer) ReadExtentStats

ReadExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) ReadStoreExtentReplicaStats

ReadStoreExtentReplicaStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) RegisterHostUUID

func (_m *TChanMetadataServiceServer) RegisterHostUUID(ctx thrift.Context, request *metadata.RegisterHostUUIDRequest) error

RegisterHostUUID provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) SealExtent

SealExtent provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) SetAckOffset

SetAckOffset provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) SetOutputHost

SetOutputHost provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) UUIDToHostAddr

func (_m *TChanMetadataServiceServer) UUIDToHostAddr(ctx thrift.Context, hostUUID string) (string, error)

UUIDToHostAddr provides a mock function with given fields: ctx, hostUUID

func (*TChanMetadataServiceServer) UpdateConsumerGroup

UpdateConsumerGroup provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataServiceServer) UpdateConsumerGroupExtentStatus

func (_m *TChanMetadataServiceServer) UpdateConsumerGroupExtentStatus(ctx thrift.Context, request *metadata.UpdateConsumerGroupExtentStatusRequest) error

UpdateConsumerGroupExtentStatus provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) UpdateDestination

UpdateDestination provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataServiceServer) UpdateDestinationDLQCursors

UpdateDestinationDLQCursors provides a mock function with given fields: ctx, updateRequest

func (*TChanMetadataServiceServer) UpdateExtentReplicaStats

func (_m *TChanMetadataServiceServer) UpdateExtentReplicaStats(ctx thrift.Context, request *metadata.UpdateExtentReplicaStatsRequest) error

UpdateExtentReplicaStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) UpdateExtentStats

UpdateExtentStats provides a mock function with given fields: ctx, request

func (*TChanMetadataServiceServer) UpdateStoreExtentReplicaStats

func (_m *TChanMetadataServiceServer) UpdateStoreExtentReplicaStats(ctx thrift.Context, request *metadata.UpdateStoreExtentReplicaStatsRequest) error

UpdateStoreExtentReplicaStats provides a mock function with given fields: ctx, request

Jump to

Keyboard shortcuts

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