sharddistributor

type Client interface {
	GetShardOwner(context.Context, *types.GetShardOwnerRequest, ...yarpc.CallOption) (*types.GetShardOwnerResponse, error)
	WatchNamespaceState(context.Context, *types.WatchNamespaceStateRequest, ...yarpc.CallOption) (WatchNamespaceStateClient, error)
}

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

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

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

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

type WatchNamespaceStateClient interface {
	Context() context.Context
	Recv(...yarpc.StreamOption) (*types.WatchNamespaceStateResponse, error)
	CloseSend(...yarpc.StreamOption) error
}