metadata

package
v1.21.0-rc1 Latest Latest
Warning

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

 Go to latest Published: May 31, 2017 License: MIT Imports: 4 Imported by: 6

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 

func (_m *MetadataExposable) ListExtentsStats(request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

ListExtentsStats provides a mock function with given fields: request

func (*MetadataExposable) ListHosts 

func (_m *MetadataExposable) ListHosts(request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

ListHosts provides a mock function with given fields: request

func (*MetadataExposable) ListInputHostExtentsStats 

func (_m *MetadataExposable) ListInputHostExtentsStats(request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

ListInputHostExtentsStats provides a mock function with given fields: request

func (*MetadataExposable) ListStoreExtentsStats 

func (_m *MetadataExposable) ListStoreExtentsStats(request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

ListStoreExtentsStats provides a mock function with given fields: request

func (*MetadataExposable) ReadConsumerGroupExtent 

func (_m *MetadataExposable) ReadConsumerGroupExtent(request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

ReadConsumerGroupExtent provides a mock function with given fields: request

func (*MetadataExposable) ReadConsumerGroupExtents 

func (_m *MetadataExposable) ReadConsumerGroupExtents(request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

ReadConsumerGroupExtents provides a mock function with given fields: request

func (*MetadataExposable) ReadExtentStats 

func (_m *MetadataExposable) ReadExtentStats(request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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 *shared.CreateConsumerGroupExtentRequest) error

CreateConsumerGroupExtent provides a mock function with given fields: request

func (*MetadataService) CreateConsumerGroupUUID added in v1.26.0 

func (_m *MetadataService) CreateConsumerGroupUUID(registerRequest *shared.CreateConsumerGroupUUIDRequest) (*shared.ConsumerGroupDescription, error)

CreateConsumerGroupUUID provides a mock function with given fields: registerRequest

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 

func (_m *MetadataService) CreateExtent(request *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)

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 

func (_m *MetadataService) ListConsumerGroups(listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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 

func (_m *MetadataService) ListExtentsStats(request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

ListExtentsStats provides a mock function with given fields: request

func (*MetadataService) ListHosts 

func (_m *MetadataService) ListHosts(request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

ListHosts provides a mock function with given fields: request

func (*MetadataService) ListInputHostExtentsStats 

func (_m *MetadataService) ListInputHostExtentsStats(request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

ListInputHostExtentsStats provides a mock function with given fields: request

func (*MetadataService) ListStoreExtentsStats 

func (_m *MetadataService) ListStoreExtentsStats(request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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 

func (_m *MetadataService) ReadConsumerGroup(getRequest *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

ReadConsumerGroup provides a mock function with given fields: getRequest

func (*MetadataService) ReadConsumerGroupExtent 

func (_m *MetadataService) ReadConsumerGroupExtent(request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

ReadConsumerGroupExtent provides a mock function with given fields: request

func (*MetadataService) ReadConsumerGroupExtents 

func (_m *MetadataService) ReadConsumerGroupExtents(request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

ReadConsumerGroupExtents provides a mock function with given fields: request

func (*MetadataService) ReadDestination 

func (_m *MetadataService) ReadDestination(getRequest *shared.ReadDestinationRequest) (*shared.DestinationDescription, error)

ReadDestination provides a mock function with given fields: getRequest

func (*MetadataService) ReadExtentStats 

func (_m *MetadataService) ReadExtentStats(request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

ReadExtentStats provides a mock function with given fields: request

func (*MetadataService) ReadStoreExtentReplicaStats 

func (_m *MetadataService) ReadStoreExtentReplicaStats(request *metadata.ReadStoreExtentReplicaStatsRequest) (*metadata.ReadStoreExtentReplicaStatsResult_, error)

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 *shared.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 *shared.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 

func (_m *MetadataService) UpdateExtentStats(request *metadata.UpdateExtentStatsRequest) (*metadata.UpdateExtentStatsResult_, error)

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 

func (_m *MetadataServiceListConsumerGroupsInCall) Done() error

Done provides a mock function with given fields:

func (*MetadataServiceListConsumerGroupsInCall) Flush 

func (_m *MetadataServiceListConsumerGroupsInCall) Flush() error

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 

func (_m *MetadataServiceListConsumerGroupsInCall) Write(arg *shared.ConsumerGroupDescription) error

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 

func (_m *MetadataServiceListConsumerGroupsOutCall) Read() (*shared.ConsumerGroupDescription, error)

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 

func (_m *MetadataServiceListDestinationsByUUIDInCall) Done() error

Done provides a mock function with given fields:

func (*MetadataServiceListDestinationsByUUIDInCall) Flush 

func (_m *MetadataServiceListDestinationsByUUIDInCall) Flush() error

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 

func (_m *MetadataServiceListDestinationsByUUIDInCall) Write(arg *shared.DestinationDescription) error

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 

func (_m *MetadataServiceListDestinationsByUUIDOutCall) Read() (*shared.DestinationDescription, error)

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 

func (_m *MetadataServiceListDestinationsInCall) Done() error

Done provides a mock function with given fields:

func (*MetadataServiceListDestinationsInCall) Flush 

func (_m *MetadataServiceListDestinationsInCall) Flush() error

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 

func (_m *MetadataServiceListDestinationsInCall) Write(arg *shared.DestinationDescription) error

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 

func (_m *MetadataServiceListDestinationsOutCall) Read() (*shared.DestinationDescription, error)

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 

func (_m *MetadataServiceListExtentsStatsStreamInCall) Done() error

Done provides a mock function with given fields:

func (*MetadataServiceListExtentsStatsStreamInCall) Flush 

func (_m *MetadataServiceListExtentsStatsStreamInCall) Flush() error

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 

func (_m *MetadataServiceListExtentsStatsStreamInCall) Write(arg *shared.ExtentStats) error

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 

func (_m *MetadataServiceListExtentsStatsStreamOutCall) Read() (*shared.ExtentStats, error)

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 

func (_m *MetadataServiceReadConsumerGroupExtentsStreamInCall) Done() error

Done provides a mock function with given fields:

func (*MetadataServiceReadConsumerGroupExtentsStreamInCall) Flush 

func (_m *MetadataServiceReadConsumerGroupExtentsStreamInCall) Flush() error

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 

func (_m *MetadataServiceReadConsumerGroupExtentsStreamInCall) Write(arg *shared.ConsumerGroupExtent) error

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 

func (_m *MetadataServiceReadConsumerGroupExtentsStreamOutCall) Read() (*shared.ConsumerGroupExtent, error)

Read provides a mock function with given fields:

func (*MetadataServiceReadConsumerGroupExtentsStreamOutCall) ResponseHeaders 

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

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 

func (_m *TChanMetadataExposable) ListAllConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataExposable) ListConsumerGroups added in v0.2.0 

func (_m *TChanMetadataExposable) ListConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataExposable) ListDestinations added in v0.2.0 

func (_m *TChanMetadataExposable) ListDestinations(ctx thrift.Context, listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataExposable) ListDestinationsByUUID added in v0.2.0 

func (_m *TChanMetadataExposable) ListDestinationsByUUID(ctx thrift.Context, listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataExposable) ListEntityOps added in v0.2.0 

func (_m *TChanMetadataExposable) ListEntityOps(ctx thrift.Context, listRequest *metadata.ListEntityOpsRequest) (*metadata.ListEntityOpsResult_, error)

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

func (*TChanMetadataExposable) ListExtentsStats 

func (_m *TChanMetadataExposable) ListExtentsStats(ctx thrift.Context, request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

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

func (*TChanMetadataExposable) ListHosts 

func (_m *TChanMetadataExposable) ListHosts(ctx thrift.Context, request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

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

func (*TChanMetadataExposable) ListInputHostExtentsStats 

func (_m *TChanMetadataExposable) ListInputHostExtentsStats(ctx thrift.Context, request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

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

func (*TChanMetadataExposable) ListStoreExtentsStats 

func (_m *TChanMetadataExposable) ListStoreExtentsStats(ctx thrift.Context, request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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

func (*TChanMetadataExposable) ReadConsumerGroup added in v0.2.0 

func (_m *TChanMetadataExposable) ReadConsumerGroup(ctx thrift.Context, getRequest *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataExposable) ReadConsumerGroupByUUID added in v0.2.0 

func (_m *TChanMetadataExposable) ReadConsumerGroupByUUID(ctx thrift.Context, request *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataExposable) ReadConsumerGroupExtent 

func (_m *TChanMetadataExposable) ReadConsumerGroupExtent(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

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

func (*TChanMetadataExposable) ReadConsumerGroupExtents 

func (_m *TChanMetadataExposable) ReadConsumerGroupExtents(ctx thrift.Context, request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

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

func (*TChanMetadataExposable) ReadConsumerGroupExtentsByExtUUID added in v0.2.0 

func (_m *TChanMetadataExposable) ReadConsumerGroupExtentsByExtUUID(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentsByExtUUIDRequest) (*metadata.ReadConsumerGroupExtentsByExtUUIDResult_, error)

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

func (*TChanMetadataExposable) ReadDestination added in v0.2.0 

func (_m *TChanMetadataExposable) ReadDestination(ctx thrift.Context, getRequest *shared.ReadDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataExposable) ReadExtentStats 

func (_m *TChanMetadataExposable) ReadExtentStats(ctx thrift.Context, request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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

func (*TChanMetadataExposable) ReadServiceConfig added in v0.2.0 

func (_m *TChanMetadataExposable) ReadServiceConfig(ctx thrift.Context, request *metadata.ReadServiceConfigRequest) (*metadata.ReadServiceConfigResult_, error)

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 

func (_m *TChanMetadataExposableClient) ListExtentsStats(ctx thrift.Context, request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

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

func (*TChanMetadataExposableClient) ListHosts 

func (_m *TChanMetadataExposableClient) ListHosts(ctx thrift.Context, request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

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

func (*TChanMetadataExposableClient) ListInputHostExtentsStats 

func (_m *TChanMetadataExposableClient) ListInputHostExtentsStats(ctx thrift.Context, request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

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

func (*TChanMetadataExposableClient) ListStoreExtentsStats 

func (_m *TChanMetadataExposableClient) ListStoreExtentsStats(ctx thrift.Context, request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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

func (*TChanMetadataExposableClient) ReadConsumerGroupExtent 

func (_m *TChanMetadataExposableClient) ReadConsumerGroupExtent(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

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

func (*TChanMetadataExposableClient) ReadConsumerGroupExtents 

func (_m *TChanMetadataExposableClient) ReadConsumerGroupExtents(ctx thrift.Context, request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

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

func (*TChanMetadataExposableClient) ReadExtentStats 

func (_m *TChanMetadataExposableClient) ReadExtentStats(ctx thrift.Context, request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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 

func (_m *TChanMetadataExposableServer) ListExtentsStats(ctx thrift.Context, request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

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

func (*TChanMetadataExposableServer) ListHosts 

func (_m *TChanMetadataExposableServer) ListHosts(ctx thrift.Context, request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

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

func (*TChanMetadataExposableServer) ListInputHostExtentsStats 

func (_m *TChanMetadataExposableServer) ListInputHostExtentsStats(ctx thrift.Context, request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

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

func (*TChanMetadataExposableServer) ListStoreExtentsStats 

func (_m *TChanMetadataExposableServer) ListStoreExtentsStats(ctx thrift.Context, request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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

func (*TChanMetadataExposableServer) ReadConsumerGroupExtent 

func (_m *TChanMetadataExposableServer) ReadConsumerGroupExtent(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

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

func (*TChanMetadataExposableServer) ReadConsumerGroupExtents 

func (_m *TChanMetadataExposableServer) ReadConsumerGroupExtents(ctx thrift.Context, request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

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

func (*TChanMetadataExposableServer) ReadExtentStats 

func (_m *TChanMetadataExposableServer) ReadExtentStats(ctx thrift.Context, request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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 

func (_m *TChanMetadataService) CreateConsumerGroup(ctx thrift.Context, createRequest *shared.CreateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataService) CreateConsumerGroupExtent 

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

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

func (*TChanMetadataService) CreateConsumerGroupUUID added in v1.26.0 

func (_m *TChanMetadataService) CreateConsumerGroupUUID(ctx thrift.Context, createRequest *shared.CreateConsumerGroupUUIDRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataService) CreateDestination 

func (_m *TChanMetadataService) CreateDestination(ctx thrift.Context, createRequest *shared.CreateDestinationRequest) (*shared.DestinationDescription, error)

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 

func (_m *TChanMetadataService) CreateExtent(ctx thrift.Context, request *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)

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 

func (_m *TChanMetadataService) ListAllConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataService) ListConsumerGroups 

func (_m *TChanMetadataService) ListConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataService) ListDestinationExtents added in v0.2.0 

func (_m *TChanMetadataService) ListDestinationExtents(ctx thrift.Context, request *metadata.ListDestinationExtentsRequest) (*metadata.ListDestinationExtentsResult_, error)

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

func (*TChanMetadataService) ListDestinations 

func (_m *TChanMetadataService) ListDestinations(ctx thrift.Context, listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataService) ListDestinationsByUUID 

func (_m *TChanMetadataService) ListDestinationsByUUID(ctx thrift.Context, listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataService) ListEntityOps 

func (_m *TChanMetadataService) ListEntityOps(ctx thrift.Context, listRequest *metadata.ListEntityOpsRequest) (*metadata.ListEntityOpsResult_, error)

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

func (*TChanMetadataService) ListExtentsStats 

func (_m *TChanMetadataService) ListExtentsStats(ctx thrift.Context, request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

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

func (*TChanMetadataService) ListHosts 

func (_m *TChanMetadataService) ListHosts(ctx thrift.Context, request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

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

func (*TChanMetadataService) ListInputHostExtentsStats 

func (_m *TChanMetadataService) ListInputHostExtentsStats(ctx thrift.Context, request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

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

func (*TChanMetadataService) ListStoreExtentsStats 

func (_m *TChanMetadataService) ListStoreExtentsStats(ctx thrift.Context, request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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 

func (_m *TChanMetadataService) ReadConsumerGroup(ctx thrift.Context, getRequest *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataService) ReadConsumerGroupByUUID 

func (_m *TChanMetadataService) ReadConsumerGroupByUUID(ctx thrift.Context, request *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataService) ReadConsumerGroupExtent 

func (_m *TChanMetadataService) ReadConsumerGroupExtent(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

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

func (*TChanMetadataService) ReadConsumerGroupExtents 

func (_m *TChanMetadataService) ReadConsumerGroupExtents(ctx thrift.Context, request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

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

func (*TChanMetadataService) ReadConsumerGroupExtentsByExtUUID 

func (_m *TChanMetadataService) ReadConsumerGroupExtentsByExtUUID(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentsByExtUUIDRequest) (*metadata.ReadConsumerGroupExtentsByExtUUIDResult_, error)

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

func (*TChanMetadataService) ReadConsumerGroupExtentsLite added in v0.2.0 

func (_m *TChanMetadataService) ReadConsumerGroupExtentsLite(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentsLiteRequest) (*metadata.ReadConsumerGroupExtentsLiteResult_, error)

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

func (*TChanMetadataService) ReadDestination 

func (_m *TChanMetadataService) ReadDestination(ctx thrift.Context, getRequest *shared.ReadDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataService) ReadExtentStats 

func (_m *TChanMetadataService) ReadExtentStats(ctx thrift.Context, request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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

func (*TChanMetadataService) ReadHostInfo 

func (_m *TChanMetadataService) ReadHostInfo(ctx thrift.Context, request *metadata.ReadHostInfoRequest) (*metadata.ReadHostInfoResult_, error)

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

func (*TChanMetadataService) ReadServiceConfig 

func (_m *TChanMetadataService) ReadServiceConfig(ctx thrift.Context, request *metadata.ReadServiceConfigRequest) (*metadata.ReadServiceConfigResult_, error)

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

func (*TChanMetadataService) ReadStoreExtentReplicaStats 

func (_m *TChanMetadataService) ReadStoreExtentReplicaStats(ctx thrift.Context, request *metadata.ReadStoreExtentReplicaStatsRequest) (*metadata.ReadStoreExtentReplicaStatsResult_, error)

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 *shared.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 

func (_m *TChanMetadataService) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataService) UpdateConsumerGroupExtentStatus 

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

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

func (*TChanMetadataService) UpdateDestination 

func (_m *TChanMetadataService) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)

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 

func (_m *TChanMetadataService) UpdateExtentStats(ctx thrift.Context, request *metadata.UpdateExtentStatsRequest) (*metadata.UpdateExtentStatsResult_, error)

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 

func (_m *TChanMetadataServiceClient) CreateConsumerGroup(ctx thrift.Context, registerRequest *shared.CreateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceClient) CreateConsumerGroupExtent 

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

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

func (*TChanMetadataServiceClient) CreateDestination 

func (_m *TChanMetadataServiceClient) CreateDestination(ctx thrift.Context, createRequest *shared.CreateDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataServiceClient) CreateDestinationUUID 

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

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

func (*TChanMetadataServiceClient) CreateExtent 

func (_m *TChanMetadataServiceClient) CreateExtent(ctx thrift.Context, request *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)

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

func (*TChanMetadataServiceClient) CreateHostInfo 

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

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 

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

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 

func (_m *TChanMetadataServiceClient) ListAllConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataServiceClient) ListConsumerGroups 

func (_m *TChanMetadataServiceClient) ListConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataServiceClient) ListDestinationExtents added in v0.2.0 

func (_m *TChanMetadataServiceClient) ListDestinationExtents(ctx thrift.Context, request *metadata.ListDestinationExtentsRequest) (*metadata.ListDestinationExtentsResult_, error)

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

func (*TChanMetadataServiceClient) ListDestinations 

func (_m *TChanMetadataServiceClient) ListDestinations(ctx thrift.Context, listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataServiceClient) ListDestinationsByUUID 

func (_m *TChanMetadataServiceClient) ListDestinationsByUUID(ctx thrift.Context, listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataServiceClient) ListEntityOps 

func (_m *TChanMetadataServiceClient) ListEntityOps(ctx thrift.Context, listRequest *metadata.ListEntityOpsRequest) (*metadata.ListEntityOpsResult_, error)

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

func (*TChanMetadataServiceClient) ListExtentsStats 

func (_m *TChanMetadataServiceClient) ListExtentsStats(ctx thrift.Context, request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

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

func (*TChanMetadataServiceClient) ListHosts 

func (_m *TChanMetadataServiceClient) ListHosts(ctx thrift.Context, request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

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

func (*TChanMetadataServiceClient) ListInputHostExtentsStats 

func (_m *TChanMetadataServiceClient) ListInputHostExtentsStats(ctx thrift.Context, request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

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

func (*TChanMetadataServiceClient) ListStoreExtentsStats 

func (_m *TChanMetadataServiceClient) ListStoreExtentsStats(ctx thrift.Context, request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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

func (*TChanMetadataServiceClient) MoveExtent 

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

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

func (*TChanMetadataServiceClient) ReadConsumerGroup 

func (_m *TChanMetadataServiceClient) ReadConsumerGroup(ctx thrift.Context, getRequest *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceClient) ReadConsumerGroupByUUID 

func (_m *TChanMetadataServiceClient) ReadConsumerGroupByUUID(ctx thrift.Context, getRequest *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceClient) ReadConsumerGroupExtent 

func (_m *TChanMetadataServiceClient) ReadConsumerGroupExtent(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

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

func (*TChanMetadataServiceClient) ReadConsumerGroupExtents 

func (_m *TChanMetadataServiceClient) ReadConsumerGroupExtents(ctx thrift.Context, request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

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

func (*TChanMetadataServiceClient) ReadConsumerGroupExtentsByExtUUID 

func (_m *TChanMetadataServiceClient) ReadConsumerGroupExtentsByExtUUID(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentsByExtUUIDRequest) (*metadata.ReadConsumerGroupExtentsByExtUUIDResult_, error)

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

func (*TChanMetadataServiceClient) ReadConsumerGroupExtentsLite added in v0.2.0 

func (_m *TChanMetadataServiceClient) ReadConsumerGroupExtentsLite(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentsLiteRequest) (*metadata.ReadConsumerGroupExtentsLiteResult_, error)

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

func (*TChanMetadataServiceClient) ReadDestination 

func (_m *TChanMetadataServiceClient) ReadDestination(ctx thrift.Context, getRequest *shared.ReadDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataServiceClient) ReadExtentStats 

func (_m *TChanMetadataServiceClient) ReadExtentStats(ctx thrift.Context, request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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

func (*TChanMetadataServiceClient) ReadHostInfo 

func (_m *TChanMetadataServiceClient) ReadHostInfo(ctx thrift.Context, request *metadata.ReadHostInfoRequest) (*metadata.ReadHostInfoResult_, error)

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

func (*TChanMetadataServiceClient) ReadServiceConfig 

func (_m *TChanMetadataServiceClient) ReadServiceConfig(ctx thrift.Context, request *metadata.ReadServiceConfigRequest) (*metadata.ReadServiceConfigResult_, error)

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

func (*TChanMetadataServiceClient) ReadStoreExtentReplicaStats 

func (_m *TChanMetadataServiceClient) ReadStoreExtentReplicaStats(ctx thrift.Context, request *metadata.ReadStoreExtentReplicaStatsRequest) (*metadata.ReadStoreExtentReplicaStatsResult_, error)

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 

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

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

func (*TChanMetadataServiceClient) SetAckOffset 

func (_m *TChanMetadataServiceClient) SetAckOffset(ctx thrift.Context, request *shared.SetAckOffsetRequest) error

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

func (*TChanMetadataServiceClient) SetOutputHost 

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

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 

func (_m *TChanMetadataServiceClient) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceClient) UpdateConsumerGroupExtentStatus 

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

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

func (*TChanMetadataServiceClient) UpdateDestination 

func (_m *TChanMetadataServiceClient) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataServiceClient) UpdateDestinationDLQCursors 

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

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 

func (_m *TChanMetadataServiceClient) UpdateExtentStats(ctx thrift.Context, request *metadata.UpdateExtentStatsRequest) (*metadata.UpdateExtentStatsResult_, error)

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

func (*TChanMetadataServiceClient) UpdateHostInfo 

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

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 

func (_m *TChanMetadataServiceServer) CreateConsumerGroup(ctx thrift.Context, registerRequest *shared.CreateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceServer) CreateConsumerGroupExtent 

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

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

func (*TChanMetadataServiceServer) CreateDestination 

func (_m *TChanMetadataServiceServer) CreateDestination(ctx thrift.Context, createRequest *shared.CreateDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataServiceServer) CreateExtent 

func (_m *TChanMetadataServiceServer) CreateExtent(ctx thrift.Context, request *shared.CreateExtentRequest) (*shared.CreateExtentResult_, error)

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 

func (_m *TChanMetadataServiceServer) ListConsumerGroups(ctx thrift.Context, listRequest *shared.ListConsumerGroupRequest) (*shared.ListConsumerGroupResult_, error)

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

func (*TChanMetadataServiceServer) ListDestinations 

func (_m *TChanMetadataServiceServer) ListDestinations(ctx thrift.Context, listRequest *shared.ListDestinationsRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataServiceServer) ListDestinationsByUUID 

func (_m *TChanMetadataServiceServer) ListDestinationsByUUID(ctx thrift.Context, listRequest *shared.ListDestinationsByUUIDRequest) (*shared.ListDestinationsResult_, error)

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

func (*TChanMetadataServiceServer) ListExtentsStats 

func (_m *TChanMetadataServiceServer) ListExtentsStats(ctx thrift.Context, request *shared.ListExtentsStatsRequest) (*shared.ListExtentsStatsResult_, error)

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

func (*TChanMetadataServiceServer) ListHosts 

func (_m *TChanMetadataServiceServer) ListHosts(ctx thrift.Context, request *metadata.ListHostsRequest) (*metadata.ListHostsResult_, error)

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

func (*TChanMetadataServiceServer) ListInputHostExtentsStats 

func (_m *TChanMetadataServiceServer) ListInputHostExtentsStats(ctx thrift.Context, request *metadata.ListInputHostExtentsStatsRequest) (*metadata.ListInputHostExtentsStatsResult_, error)

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

func (*TChanMetadataServiceServer) ListStoreExtentsStats 

func (_m *TChanMetadataServiceServer) ListStoreExtentsStats(ctx thrift.Context, request *metadata.ListStoreExtentsStatsRequest) (*metadata.ListStoreExtentsStatsResult_, error)

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

func (*TChanMetadataServiceServer) MoveExtent 

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

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

func (*TChanMetadataServiceServer) ReadConsumerGroup 

func (_m *TChanMetadataServiceServer) ReadConsumerGroup(ctx thrift.Context, getRequest *shared.ReadConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceServer) ReadConsumerGroupExtent 

func (_m *TChanMetadataServiceServer) ReadConsumerGroupExtent(ctx thrift.Context, request *metadata.ReadConsumerGroupExtentRequest) (*metadata.ReadConsumerGroupExtentResult_, error)

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

func (*TChanMetadataServiceServer) ReadConsumerGroupExtents 

func (_m *TChanMetadataServiceServer) ReadConsumerGroupExtents(ctx thrift.Context, request *shared.ReadConsumerGroupExtentsRequest) (*shared.ReadConsumerGroupExtentsResult_, error)

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

func (*TChanMetadataServiceServer) ReadDestination 

func (_m *TChanMetadataServiceServer) ReadDestination(ctx thrift.Context, getRequest *shared.ReadDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataServiceServer) ReadExtentStats 

func (_m *TChanMetadataServiceServer) ReadExtentStats(ctx thrift.Context, request *metadata.ReadExtentStatsRequest) (*metadata.ReadExtentStatsResult_, error)

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

func (*TChanMetadataServiceServer) ReadStoreExtentReplicaStats 

func (_m *TChanMetadataServiceServer) ReadStoreExtentReplicaStats(ctx thrift.Context, request *metadata.ReadStoreExtentReplicaStatsRequest) (*metadata.ReadStoreExtentReplicaStatsResult_, error)

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 

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

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

func (*TChanMetadataServiceServer) SetAckOffset 

func (_m *TChanMetadataServiceServer) SetAckOffset(ctx thrift.Context, request *shared.SetAckOffsetRequest) error

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

func (*TChanMetadataServiceServer) SetOutputHost 

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

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 

func (_m *TChanMetadataServiceServer) UpdateConsumerGroup(ctx thrift.Context, updateRequest *shared.UpdateConsumerGroupRequest) (*shared.ConsumerGroupDescription, error)

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

func (*TChanMetadataServiceServer) UpdateConsumerGroupExtentStatus 

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

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

func (*TChanMetadataServiceServer) UpdateDestination 

func (_m *TChanMetadataServiceServer) UpdateDestination(ctx thrift.Context, updateRequest *shared.UpdateDestinationRequest) (*shared.DestinationDescription, error)

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

func (*TChanMetadataServiceServer) UpdateDestinationDLQCursors 

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

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 

func (_m *TChanMetadataServiceServer) UpdateExtentStats(ctx thrift.Context, request *metadata.UpdateExtentStatsRequest) (*metadata.UpdateExtentStatsResult_, error)

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

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.